生活随笔
收集整理的這篇文章主要介紹了
最简实例说明wait、notify、notifyAll的使用方法
小編覺(jué)得挺不錯(cuò)的,現(xiàn)在分享給大家,幫大家做個(gè)參考.
/**
*? 轉(zhuǎn)載請(qǐng)注明作者longdick? ? http://longdick.iteye.com
*
*/
?
wait()、notify()、notifyAll()是三個(gè)定義在Object類(lèi)里的方法，可以用來(lái)控制線程的狀態(tài)。
這三個(gè)方法最終調(diào)用的都是jvm級(jí)的native方法。隨著jvm運(yùn)行平臺(tái)的不同可能有些許差異。
?
- 如果對(duì)象調(diào)用了wait方法就會(huì)使持有該對(duì)象的線程把該對(duì)象的控制權(quán)交出去，然后處于等待狀態(tài)。
- 如果對(duì)象調(diào)用了notify方法就會(huì)通知某個(gè)正在等待這個(gè)對(duì)象的控制權(quán)的線程可以繼續(xù)運(yùn)行。
- 如果對(duì)象調(diào)用了notifyAll方法就會(huì)通知所有等待這個(gè)對(duì)象控制權(quán)的線程繼續(xù)運(yùn)行。
?
其中wait方法有三個(gè)over load方法：
wait()
wait(long)
wait(long,int)
wait方法通過(guò)參數(shù)可以指定等待的時(shí)長(zhǎng)。如果沒(méi)有指定參數(shù)，默認(rèn)一直等待直到被通知。
?
?
以下是一個(gè)演示代碼，以最簡(jiǎn)潔的方式說(shuō)明復(fù)雜的問(wèn)題：
簡(jiǎn)要說(shuō)明下：
NotifyThread是用來(lái)模擬3秒鐘后通知其他等待狀態(tài)的線程的線程類(lèi)；
WaitThread是用來(lái)模擬等待的線程類(lèi)；
等待的中間對(duì)象是flag，一個(gè)String對(duì)象；
main方法中同時(shí)啟動(dòng)一個(gè)Notify線程和三個(gè)wait線程；
?
?
Java代碼??
public?class?NotifyTest?{?? ????private??String?flag?=?"true";?? ?? ????class?NotifyThread?extends?Thread{?? ????????public?NotifyThread(String?name)?{?? ????????????super(name);?? ????????}?? ????????public?void?run()?{??????? ????????????try?{?? ????????????????sleep(3000);?? ????????????}?catch?(InterruptedException?e)?{?? ????????????????e.printStackTrace();?? ????????????}?? ?????????????? ????????????????flag?=?"false";?? ????????????????flag.notify();?? ????????}?? ????};?? ?? ????class?WaitThread?extends?Thread?{?? ????????public?WaitThread(String?name)?{?? ????????????super(name);?? ????????}?? ?? ????????public?void?run()?{?? ?????????????? ????????????????while?(flag!="false")?{?? ????????????????????System.out.println(getName()?+?"?begin?waiting!");?? ????????????????????long?waitTime?=?System.currentTimeMillis();?? ????????????????????try?{?? ????????????????????????flag.wait();?? ????????????????????}?catch?(InterruptedException?e)?{?? ????????????????????????e.printStackTrace();?? ????????????????????}?? ????????????????????waitTime?=?System.currentTimeMillis()?-?waitTime;?? ????????????????????System.out.println("wait?time?:"+waitTime);?? ????????????????}?? ????????????????System.out.println(getName()?+?"?end?waiting!");?? ?????????????? ????????}?? ????}?? ?? ????public?static?void?main(String[]?args)?throws?InterruptedException?{?? ????????System.out.println("Main?Thread?Run!");?? ????????NotifyTest?test?=?new?NotifyTest();?? ????????NotifyThread?notifyThread?=test.new?NotifyThread("notify01");?? ????????WaitThread?waitThread01?=?test.new?WaitThread("waiter01");?? ????????WaitThread?waitThread02?=?test.new?WaitThread("waiter02");?? ????????WaitThread?waitThread03?=?test.new?WaitThread("waiter03");?? ????????notifyThread.start();?? ????????waitThread01.start();?? ????????waitThread02.start();?? ????????waitThread03.start();?? ????}?? ?? }??
?
OK，如果你拿這段程序去運(yùn)行下的話， 會(huì)發(fā)現(xiàn)根本運(yùn)行不了，what happened？滿屏的java.lang.IllegalMonitorStateException。
沒(méi)錯(cuò)，這段程序有很多問(wèn)題，我們一個(gè)個(gè)來(lái)看。
?
首先，這兒要非常注意的幾個(gè)事實(shí)是
?
任何一個(gè)時(shí)刻，對(duì)象的控制權(quán)（monitor）只能被一個(gè)線程擁有。無(wú)論是執(zhí)行對(duì)象的wait、notify還是notifyAll方法，必須保證當(dāng)前運(yùn)行的線程取得了該對(duì)象的控制權(quán)（monitor）如果在沒(méi)有控制權(quán)的線程里執(zhí)行對(duì)象的以上三種方法，就會(huì)報(bào)java.lang.IllegalMonitorStateException異常。JVM基于多線程，默認(rèn)情況下不能保證運(yùn)行時(shí)線程的時(shí)序性
?
基于以上幾點(diǎn)事實(shí)，我們需要確保讓線程擁有對(duì)象的控制權(quán)。
也就是說(shuō)在waitThread中執(zhí)行wait方法時(shí)，要保證waitThread對(duì)flag有控制權(quán)；
在notifyThread中執(zhí)行notify方法時(shí)，要保證notifyThread對(duì)flag有控制權(quán)。
?
線程取得控制權(quán)的方法有三：
?
執(zhí)行對(duì)象的某個(gè)同步實(shí)例方法。執(zhí)行對(duì)象對(duì)應(yīng)類(lèi)的同步靜態(tài)方法。執(zhí)行對(duì)該對(duì)象加同步鎖的同步塊。
我們用第三種方法來(lái)做說(shuō)明：
將以上notify和wait方法包在同步塊中
Java代碼??
synchronized?(flag)?{?? ????????????????flag?=?"false";?? ????????????????flag.notify();?? ????????????}??
?
?
Java代碼??
synchronized?(flag)?{?? ????????????????while?(flag!="false")?{?? ????????????????????System.out.println(getName()?+?"?begin?waiting!");?? ????????????????????long?waitTime?=?System.currentTimeMillis();?? ????????????????????try?{?? ????????????????????????flag.wait();?? ????????????????????}?catch?(InterruptedException?e)?{?? ????????????????????????e.printStackTrace();?? ????????????????????}?? ????????????????????waitTime?=?System.currentTimeMillis()?-?waitTime;?? ????????????????????System.out.println("wait?time?:"+waitTime);?? ????????????????}?? ????????????????System.out.println(getName()?+?"?end?waiting!");?? ????????????}??
?
我們向前進(jìn)了一步。
問(wèn)題解決了嗎？
好像運(yùn)行還是報(bào)錯(cuò)java.lang.IllegalMonitorStateException。what happened？
?
這時(shí)的異常是由于在針對(duì)flag對(duì)象同步塊中，更改了flag對(duì)象的狀態(tài)所導(dǎo)致的。如下：
flag="false";
flag.notify();
對(duì)在同步塊中對(duì)flag進(jìn)行了賦值操作，使得flag引用的對(duì)象改變，這時(shí)候再調(diào)用notify方法時(shí)，因?yàn)闆](méi)有控制權(quán)所以拋出異常。
?
我們可以改進(jìn)一下，將flag改成一個(gè)JavaBean，然后更改它的屬性不會(huì)影響到flag的引用。
我們這里改成數(shù)組來(lái)試試，也可以達(dá)到同樣的效果：
?
?
Java代碼??
private???String?flag[]?=?{"true"};??
?
?
Java代碼??
synchronized?(flag)?{?? ????????????flag[0]?=?"false";?? ????????????flag.notify();?? ????????}??
?
?
Java代碼??
synchronized?(flag)?{?? ????????????????while?(flag[0]!="false")?{?? ????????????????????System.out.println(getName()?+?"?begin?waiting!");?? ????????????????????long?waitTime?=?System.currentTimeMillis();?? ????????????????????try?{?? ????????????????????????flag.wait();?? ?????????????????????????? ????????????????????}?catch?(InterruptedException?e)?{?? ????????????????????????e.printStackTrace();?? ????????????????????}??
?
?
這時(shí)候再運(yùn)行，不再報(bào)異常，但是線程沒(méi)有結(jié)束是吧，沒(méi)錯(cuò)，還有線程堵塞，處于wait狀態(tài)。
?
原因很簡(jiǎn)單，我們有三個(gè)wait線程，只有一個(gè)notify線程，notify線程運(yùn)行notify方法的時(shí)候，是隨機(jī)通知一個(gè)正在等待的線程，所以，現(xiàn)在應(yīng)該還有兩個(gè)線程在waiting。
?
我們只需要將NotifyThread線程類(lèi)中的flag.notify()方法改成notifyAll()就可以了。notifyAll方法會(huì)通知所有正在等待對(duì)象控制權(quán)的線程。
?
最終完成版如下：
?
?
Java代碼??
public?class?NotifyTest?{?? ????private?String?flag[]?=?{?"true"?};?? ?? ????class?NotifyThread?extends?Thread?{?? ????????public?NotifyThread(String?name)?{?? ????????????super(name);?? ????????}?? ?? ????????public?void?run()?{?? ????????????try?{?? ????????????????sleep(3000);?? ????????????}?catch?(InterruptedException?e)?{?? ????????????????e.printStackTrace();?? ????????????}?? ????????????synchronized?(flag)?{?? ????????????????flag[0]?=?"false";?? ????????????????flag.notifyAll();?? ????????????}?? ????????}?? ????};?? ?? ????class?WaitThread?extends?Thread?{?? ????????public?WaitThread(String?name)?{?? ????????????super(name);?? ????????}?? ?? ????????public?void?run()?{?? ????????????synchronized?(flag)?{?? ????????????????while?(flag[0]?!=?"false")?{?? ????????????????????System.out.println(getName()?+?"?begin?waiting!");?? ????????????????????long?waitTime?=?System.currentTimeMillis();?? ????????????????????try?{?? ????????????????????????flag.wait();?? ?? ????????????????????}?catch?(InterruptedException?e)?{?? ????????????????????????e.printStackTrace();?? ????????????????????}?? ????????????????????waitTime?=?System.currentTimeMillis()?-?waitTime;?? ????????????????????System.out.println("wait?time?:"?+?waitTime);?? ????????????????}?? ????????????????System.out.println(getName()?+?"?end?waiting!");?? ????????????}?? ????????}?? ????}?? ?? ????public?static?void?main(String[]?args)?throws?InterruptedException?{?? ????????System.out.println("Main?Thread?Run!");?? ????????NotifyTest?test?=?new?NotifyTest();?? ????????NotifyThread?notifyThread?=?test.new?NotifyThread("notify01");?? ????????WaitThread?waitThread01?=?test.new?WaitThread("waiter01");?? ????????WaitThread?waitThread02?=?test.new?WaitThread("waiter02");?? ????????WaitThread?waitThread03?=?test.new?WaitThread("waiter03");?? ????????notifyThread.start();?? ????????waitThread01.start();?? ????????waitThread02.start();?? ????????waitThread03.start();?? ????}?? ?? } ? from:?http://longdick.iteye.com/blog/453615
總結(jié)
以上是生活随笔為你收集整理的最简实例说明wait、notify、notifyAll的使用方法的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。
如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。
