1. 程式人生 > >【轉】Java學習---線程間的通信

【轉】Java學習---線程間的通信

更強 裏的 兩個 sub 優先 網絡 sync 獲取 操作系統

【原文】https://www.toutiao.com/i6572378564534993415/

兩個線程間的通信

這是我們之前的線程。

技術分享圖片

執行效果:誰搶到資源,誰運行~

技術分享圖片

實現線程交替執行:

技術分享圖片

這裏主要用到了兩個內容

1)創建一個標記 flag,讓程序進行判斷:

當flag != 1 時,print1 進入等待,執行 print2,然後讓 flag=1,喚醒正在等待·的線程,

當flag != 0 時,print2 進入等待,執行 print1 ,讓後讓 flag=0,喚醒正在等待的線程。

2)在 object 類中有 wait() 和 notify() 方法,可以對線程進行等待和喚醒的操作

技術分享圖片

多個線程間的通信

兩個線程搞定了,那麽再多一點呢?

這個時候用 notify() 方法就不夠了,這個方法只能喚醒單個的線程,要用notifyAll,喚醒所有正在等待的線程,然後讓他們自行匹配,誰滿足條件誰就運行~

技術分享圖片

註意:

在同步代碼塊中,用哪個對象鎖,就用那個對象調用 wait() 方法。

sleep() 和 wait() 方法的區別

這兩個方法的功能很像,但是還是有一點區別的~

第一點:

sleep()方法必須給一個參數,參數就是等待的時間,時間到了自動醒來。

wait()方法也可以傳入參數,程序在參數代表的時間結束後進入等待,不傳參數表示程序直接進入等待。

第二點:

sleep()方法在同步代碼塊或同步函數中,不釋放鎖。

wait()方法在同步代碼塊或同步函數中,釋放鎖。

JDK1.5的特性

互斥鎖 ReentrantLock

一個可重入的互斥鎖 Lock,它具有與使用 synchronized 方法和語句所訪問的隱式監視器鎖相同的一些基本行為和語義,但功能更強大。

這裏面有一個 newCondition()方法

可以返回一個 Condition 實例。 這個實例可以調用下面的方法,我們主要用到了圈起的兩個方法~

技術分享圖片

那麽我們實現上面的功能的代碼,就可以這樣來寫

技術分享圖片

線程的生命周期

就是一個線程的生命周期,小夥伴們看一下,學了一回線程,這個東西還是要了解一下的~

技術分享圖片

圖片自來網絡

線程組

線程組概述

Java 中使用 ThreadGroup 來表示線程組,它可以對一批線程進行分類管理,Java 允許程序直接對線程組進行控制。

默認情況下,所有的線程都屬於主線程組。

getThreadGroup()

通過線程對象獲取他所屬於的組

getName()

通過線程組對象獲取他組的名字

技術分享圖片

我們也可以給線程設置分組

步驟如下:

1)ThreadGroup(String name) 創建線程組對象並給其賦值名字

2)創建線程對象

3)Thread(ThreadGroup, Runnable,name)

4)設置整組的優先級或者守護線程

代碼演示:

技術分享圖片

線程池

程序啟動一個新線程成本是比較高的,因為它涉及到要與操作系統進行交互。而使用線程池可以很好的提高性能,尤其是當程序中要創建大量生存期很短的線程時,更應該考慮使用線程池。

線程池裏的每一個線程代碼結束後,並不會死亡,而是再次回到線程池中成為空閑狀態,等待下一個對象來使用。(從JDK5開始,Java內置支持線程池)

內置線程池的使用概述

JDK5新增了一個Executors工廠類來產生線程池,有如下幾個方法

newFixedThreadPool(int nThreads)

newSingleThreadExecutor()

這些方法的返回值是 ExecutorService 對象,該對象表示一個線程池,可以執行 Runnable 對象或者 Callable 對象代表的線程。它提供了如下方法

submit(Runnable task)

submit(Callable<T> task)

使用步驟:

1)創建線程池對象

2)創建Runnable實例

3)提交Runnable實例

4)關閉線程池

代碼演示:

技術分享圖片

【轉】Java學習---線程間的通信