詳細(xì)分析java線程wait和notify
wait()和notify()是直接隸屬于Object類,也就是說,所有對象都擁有這一對方法。初看起來這十分 不可思議,但是實(shí)際上卻是很自然的,因?yàn)檫@一對方法阻塞時(shí)要釋放占用的鎖,而鎖是任何對象都具有的,調(diào)用任意對象的 wait() 方法導(dǎo)致線程阻塞,并且該對象上的鎖被釋放。而調(diào)用任意對象的notify()方法則導(dǎo)致因調(diào)用該對象的wait() 方法而阻塞的線程中隨機(jī)選擇的一個(gè)解除阻塞(但要等到獲得鎖后才真正可執(zhí)行)。
其次,wait()和notify()可在任何位置調(diào)用,但是這一對方法卻必須在 synchronized 方法或塊中調(diào)用,理由也很簡單,只有在 synchronized 方法或塊中當(dāng)前線程才占有鎖,才有鎖可以釋放。同樣的道理,調(diào)用這一對方法的對象上的鎖必須為當(dāng)前線程所擁有,這樣才有鎖可以 釋放。因此,方法調(diào)用必須放置在這樣的 synchronized 方法或塊中,該方法或塊的加鎖對象就是調(diào)用這些方法的對象。若不滿足這一條 件,則程序雖然仍能編譯,但在運(yùn)行時(shí)會出現(xiàn)IllegalMonitorStateException 異常。
wait() 和 notify() 方法的上述特性決定了它們經(jīng)常和synchronized 方法或塊一起使用,將它們和操作系統(tǒng)的進(jìn)程間通信機(jī)制作 一個(gè)比較就會發(fā)現(xiàn)它們的相似性:synchronized方法或塊提供了類似于操作系統(tǒng)原語的功能,它們的執(zhí)行不會受到多線程機(jī)制的干擾,而這一對方法則 相當(dāng)于 block 和wakeup 原語(這一對方法均聲明為 synchronized)。它們的結(jié)合使得我們可以實(shí)現(xiàn)操作系統(tǒng)上一系列精妙的進(jìn)程間 通信的算法(如信號量算法),并用于解決各種復(fù)雜的線程間通信問題。
關(guān)于 wait() 和 notify() 方法最后再說明兩點(diǎn):
第一:調(diào)用 notify() 方法導(dǎo)致解除阻塞的線程是從因調(diào)用該對象的 wait() 方法而阻塞的線程中隨機(jī)選取的,我們無法預(yù)料哪一個(gè)線程將會被選擇,所以編程時(shí)要特別小心,避免因這種不確定性而產(chǎn)生問題。
第二:除了 notify(),還有一個(gè)方法 notifyAll() 也可起到類似作用,唯一的區(qū)別在于,調(diào)用 notifyAll() 方法將把因調(diào) 用該對象的 wait() 方法而阻塞的所有線程一次性全部解除阻塞。當(dāng)然,只有獲得鎖的那一個(gè)線程才能進(jìn)入可執(zhí)行狀態(tài)。
相關(guān)wait和notify使用demo:
/**
* <pre>
* 子線程循環(huán)10次,接著主線程循環(huán)100次,接著有回到子線程循環(huán)10次,
* 接著再回到主線程循環(huán)100次,如此執(zhí)行50次
* </pre>
* @author ketqi
*/
public class WaitNotifyDemo {
public static void main(String[] args) {
final Business business = new Business();
new Thread(new Runnable() {
@Override
public void run() {
for (int i = 1; i <= 50; i++) {
business.sub(i);
}
}
}).start();
for (int i = 1; i <= 50; i++) {
business.main(i);
}
}
}
class Business {
private boolean isMainThread = true;
public synchronized void sub(int i) {
while (!isMainThread) {
try {
this.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
for (int j = 1; j <= 10; j++) {
System.out.println("sub thread sequence of " + j + ",loop of " + i);
}
isMainThread = false;
this.notify();
}
public synchronized void main(int i) {
while (isMainThread) {
try {
this.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
for (int j = 1; j <= 100; j++) {
System.out.println("main thread sequence of " + j + ",loop of " + i);
}
isMainThread = true;
this.notify();
}
}
以上就是本文的全部內(nèi)容,希望大家可以喜歡。
相關(guān)文章
java調(diào)用python腳本引入第三方庫失敗的實(shí)現(xiàn)
本文主要介紹了java調(diào)用python腳本引入第三方庫失敗的實(shí)現(xiàn),文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2022-07-07
java使用Socket實(shí)現(xiàn)文件上傳功能
這篇文章主要為大家詳細(xì)介紹了java使用Socket實(shí)現(xiàn)文件上傳功能,文中示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2022-02-02
Spring中的AutowireCandidateResolver的具體使用詳解
這篇文章主要介紹了Spring中的AutowireCandidateResolver的具體使用詳解,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-04-04

