-
由於同一進程的多個執行緒共享同一片儲存空間,在帶來方便的同時,也帶來了存取衝突這個嚴重的問題。 Java語言提供了專門機制來解決這種衝突,有效避免了同一個資料物件被多個執行緒同時存取。
由於我們可以透過private 關鍵字來保證資料物件只能被方法訪問,所以我們只需針對方法提出一套機制,這套機制就是synchronized 關鍵字,它包括兩種用法:synchronized 方法和synchronized 區塊。
1. synchronized 方法:透過在方法聲明中加入synchronized關鍵字來聲明synchronized 方法。如:
public synchronized void accessVal(int newVal);
synchronized 方法控制對類別成員變數的存取:每個類別實例對應一把鎖,每個synchronized 方法都必須獲得呼叫該方法的類別實例的鎖方能執行,否則所屬執行緒阻塞,方法一旦執行,就獨佔該鎖,直到從該方法返回時才將鎖釋放,此後被阻塞的線程方能獲得該鎖,重新進入可執行狀態。這種機制確保了同一時刻對於每一個類別實例,其所有聲明為synchronized 的成員函數中至多只有一個處於可執行狀態(因為至多只有一個能夠獲得該類別實例對應的鎖)(注意這個說法哦!因為是一個類別實例一個鎖,所以每次對於一個物件來說,每次只有一個synchronized 方法被一個執行緒執行),從而有效避免了類別成員變數的存取衝突(只要所有可能存取類別成員變數的方法均被聲明為synchronized)。
在Java 中,不光是類別實例,每一個類別也對應一把鎖,這樣我們也可將類別的靜態成員函數宣告為synchronized ,以控制其對類別的靜態成員變數的存取。
synchronized 方法的缺陷:若將一個大的方法宣告為synchronized 將會大大影響效率,典型地,若將執行緒類別的方法run() 宣告為synchronized ,由於在執行緒的整個生命期內它一直在運行,因此將導致它對本類任何synchronized 方法的呼叫都永遠不會成功。當然我們可以透過將存取類別成員變數的程式碼放到專門的方法中,將其宣告為synchronized ,並在主方法中呼叫來解決這一問題,但是Java 為我們提供了更好的解決辦法,那就是synchronized 塊。
2. synchronized 區塊:透過synchronized關鍵字來聲明synchronized 區塊。文法如下:
synchronized(syncObject) {
//允許存取控制的程式碼
}
synchronized 區塊是這樣一個程式碼區塊,其中的程式碼必須獲得物件syncObject (如前所述,可以是類別實例或類別)的鎖方能執行,具體機制同前所述。由於可以針對任意程式碼區塊,且可任意指定上鎖的對象,故靈活性較高。
線程的阻塞(同步)
為了解決對共享儲存區的存取衝突,Java 引入了同步機制,現在讓我們來考察多個執行緒對共享資源的訪問,顯然同步機制已經不夠了,因為在任意時刻所要求的資源不一定已經準備好了被訪問,反過來,同一時刻準備好了的資源可能不只一個。為了解決這種情況下的存取控制問題,Java 引入了對阻塞機制的支援。
阻塞指的是暫停一個執行緒的執行以等待某個條件發生(如某資源就緒),學過操作系統的同學對它一定已經很熟悉了。 Java 提供了大量方法來支援阻塞,以下讓我們逐一分析。
1. sleep() 方法:sleep() 允許指定以毫秒為單位的一段時間作為參數,它使得執行緒在指定的時間內進入阻塞狀態,不能得到CPU 時間,指定的時間一過,執行緒重新進入可執行狀態。
典型地,sleep() 被用在等待某個資源就緒的情形:測試發現條件不滿足後,讓執行緒阻塞一段時間後重新測試,直到條件滿足為止。
2. suspend() 和resume() 方法(易引起死鎖,已過時):兩個方法配套使用,suspend()使得線程進入阻塞狀態,並且不會自動恢復,必須其對應的resume() 被調用,才能使得執行緒重新進入可執行狀態。典型地,suspend() 和resume() 被用在等待另一個線程產生的結果的情形:測試發現結果還沒有產生後,讓線程阻塞,另一個線程產生了結果後,調用resume() 使其恢復。
3. yield() 方法:yield() 使得執行緒放棄目前分得的CPU 時間,但是不使執行緒阻塞,即執行緒仍處於可執行狀態,隨時可能再次分得CPU 時間。呼叫yield() 的效果等價於調度程序認為該線程已執行了足夠的時間從而轉到另一個線程。
4. wait() 和notify() 方法:兩個方法搭配使用,wait() 使得執行緒進入阻塞狀態,它有兩種形式,一種允許指定以毫秒為單位的一段時間作為參數,另一種沒有參數,前者當對應的notify() 被呼叫或超出指定時間時執行緒重新進入可執行狀態,後者則必須對應的notify() 被呼叫。
初看起來它們與suspend() 和resume() 方法對沒有什麼分別,但是事實上它們是截然不同的。差異的核心在於,前面敘述的所有方法,阻塞時都不會釋放佔用的鎖(如果佔用了的話),而這一對方法則相反。
上述的核心區別導致了一系列的細節上的區別。
首先,前面敘述的所有方法都隸屬於Thread 類,但這一對卻直接隸屬於Object 類,也就是說,所有物件都擁有這一對方法。初看起來這十分不可思議,但是實際上卻是很自然的,因為這一對方法阻塞時要釋放佔用的鎖,而鎖是任何對像都具有的,調用任意對象的wait() 方法導致線程阻塞,並且該物件上的鎖被釋放。而呼叫任意物件的notify()方法則導致因呼叫該物件的wait() 方法而阻塞的執行緒中隨機選擇的一個解除阻塞(但要等到取得鎖後才真正可執行)。
其次,前面敘述的所有方法都可在任何位置調用,但是這一對方法(wait() 和notify() )卻必須在synchronized 方法或區塊中調用,理由也很簡單,只有在synchronized 方法或區塊中目前執行緒才佔有鎖,才有鎖可以釋放。同樣的道理,呼叫這一對方法的物件上的鎖必須為當前執行緒所擁有,這樣才有鎖可以釋放。因此,這一對方法呼叫必須放置在這樣的synchronized 方法或區塊中,而該方法或區塊的上鎖物件就是呼叫這一對方法的物件。若不符合此條件,程式雖然仍能編譯,但在執行時會出現IllegalMonitorStateException 異常。
wait() 和notify() 方法的上述特性決定了它們經常和synchronized 方法或區塊一起使用,將它們和作業系統的進程間通訊機製作一個比較就會發現它們的相似性:synchronized方法或區塊提供了類似於作業系統原語的功能,它們的執行不會受到多執行緒機制的干擾,而這一對方法則相當於block 和wakeup 原語(這一對方法都宣告為synchronized)。它們的結合使得我們可以實現作業系統上一系列精妙的進程間通訊的演算法(如信號量演算法),並用於解決各種複雜的線程間通訊問題。
關於wait() 和notify() 方法最後再說明兩點:
第一:呼叫notify() 方法導致解除阻塞的執行緒是從因呼叫該物件的wait() 方法而阻塞的執行緒中隨機選取的,我們無法預料哪一個執行緒將會被選擇,所以程式設計時要特別小心,避免因這種不確定性而產生問題。
第二:除了notify(),還有一個方法notifyAll() 也可起到類似作用,唯一的區別在於,呼叫notifyAll() 方法將把因呼叫該物件的wait() 方法而阻塞的所有執行緒一次性全部解除阻塞。當然,只有獲得鎖的那一個執行緒才能進入可執行狀態。
談到阻塞,就不能不談死鎖,略一分析就能發現,suspend() 方法和不指定超時期限的wait() 方法的呼叫都可能產生死鎖。遺憾的是,Java 並不在語言層級上支援死鎖的避免,我們在程式設計中必須小心地避免死鎖。
以上我們對Java 中實現線程阻塞的各種方法作了一番分析,我們重點分析了wait() 和notify() 方法,因為它們的功能最強大,使用也最靈活,但是這也導致了它們的效率較低,較容易出錯。實際使用中我們應該靈活使用各種方法,以便更好地達到我們的目的。
守護線程
守護線程是一類特殊的線程,它和普通線程的區別在於它並不是應用程式的核心部分,當一個應用程式的所有非守護線程終止運行時,即使仍然有守護線程在運行,應用程式也將終止,反之,只要有一個非守護線程在運行,應用程式就不會終止。守護線程一般被用於在後台為其它線程提供服務。
可以透過呼叫方法isDaemon() 來判斷一個線程是否為守護線程,也可以呼叫方法setDaemon() 來將一個線程設為守護線程。
執行緒組
執行緒組是一個Java 特有的概念,在Java 中,執行緒組是類ThreadGroup的對象,每個執行緒都隸屬於唯一一個執行緒組,這個執行緒組在執行緒創建時指定並在執行緒的整個生命期內都不能更改。你可以透過呼叫包含ThreadGroup 類型參數的Thread 類別建構子來指定執行緒屬的執行緒組,若沒有指定,則執行緒缺省地隸屬於名為system 的系統執行緒組。
在Java 中,除了預先建立的系統執行緒組外,所有執行緒組都必須明確建立。在Java 中,除系統執行緒組外的每個執行緒組又隸屬於另一個執行緒組,你可以在建立執行緒組時指定其所隸屬於的執行緒組,若沒有指定,則缺省地隸屬於系統執行緒組。這樣,所有執行緒組就組成了一棵以系統執行緒組為根的樹。
Java 讓我們可以對一個執行緒組中的所有執行緒同時進行操作,例如我們可以透過呼叫執行緒組的相應方法來設定其中所有執行緒的優先權,也可以啟動或阻塞其中的所有執行緒。
Java 的線程組機制的另一個重要作用是線程安全。線程組機制允許我們透過分組來區分有不同安全特性的線程,對不同組的線程進行不同的處理,也可以透過線程組的分層結構來支援不對等安全措施的採用。 Java 的ThreadGroup 類別提供了大量的方法來方便我們對線程組樹中的每一個線程組以及線程組中的每個線程進行操作。
執行緒的狀態在給定時間點上,一個執行緒只能處於一種狀態。
NEW
至今尚未啟動的執行緒處於這種狀態。
RUNNABLE
正在Java 虛擬機器中執行的執行緒處於這種狀態。
BLOCKED
受阻塞並等待某個監視器鎖的執行緒處於這種狀態。
WAITING
無限期地等待另一個執行緒來執行某一特定操作的執行緒處於這種狀態。
某一等待線程的線程狀態。某一執行緒因為呼叫下列方法之一而處於等待狀態:
不含超時值的Object.wait
不帶超時值的Thread.join
LockSupport.park
處於等待狀態的線程正等待另一個線程,以執行特定操作。 例如,已經在某一物件上呼叫了Object.wait() 的線程正等待另一個線程,以便在該物件上呼叫Object.notify() 或Object.notifyAll()。已經呼叫了Thread.join() 的執行緒正在等待指定執行緒終止。
TIMED_WAITING
等待另一個執行緒來執行取決於指定等待時間的操作的執行緒處於這種狀態。
具有指定等待時間的某一等待執行緒的執行緒狀態。某一執行緒因為呼叫以下帶有指定正等待時間的方法之一而處於定時等待狀態:
Thread.sleep
帶有超時值的Object.wait
帶有超時值的Thread.join
LockSupport.parkNanos
LockSupport.parkUntil
TERMINATED
已退出的執行緒處於這種狀態。