一、線程間等待與喚醒機(jī)制
wait()和notify()是Object類的方法,用于線程的等待與喚醒,必須搭配synchronized 鎖來使用。
多線程并發(fā)的場景下,有時需要某些線程先執(zhí)行,這些線程執(zhí)行結(jié)束后其他線程再繼續(xù)執(zhí)行。
比如: 一個長跑比賽,裁判員要等跑步運(yùn)動員沖線了才能宣判比賽結(jié)束,那裁判員線程就得等待所有的運(yùn)動員線程運(yùn)行結(jié)束后,再喚醒這個裁判線程。
二、等待方法wait()
wait 做的事情:
使當(dāng)前執(zhí)行代碼的線程進(jìn)行等待. (把線程放到等待隊列中)
釋放當(dāng)前的鎖
滿足一定條件時被喚醒, 重新嘗試獲取這個鎖.
wait 要搭配 synchronized 來使用. 脫離 synchronized 使用 wait 會直接拋出異常.
wait 結(jié)束等待的條件:
其他線程調(diào)用該對象的 notify 方法.
wait 等待時間超時 (wait 方法提供一個帶有 timeout 參數(shù)的版本, 來指定等待時間).
其他線程調(diào)用該等待線程的 interrupted 方法, 導(dǎo)致 wait 拋出 InterruptedException 異常.
注意事項(xiàng):
調(diào)用wait()方法的前提是首先要獲取該對象的鎖(synchronize對象鎖)
調(diào)用wait()方法會釋放鎖,本線程進(jìn)入等待隊列等待被喚醒,被喚醒后不是立即恢復(fù)執(zhí)行,而是進(jìn)入阻塞隊列,競爭鎖
等待方法:
1.癡漢方法,死等,線程進(jìn)入阻塞態(tài)(WAITING)直到有其他線程調(diào)用notify方法喚醒
2.等待一段時間,若在該時間內(nèi)線程被喚醒,則繼續(xù)執(zhí)行,若超過相應(yīng)時間還沒有其他線程喚醒此線程,此線程不再等待,恢復(fù)執(zhí)行。
調(diào)用wait方法之后:
三、喚醒方法notify()
notify 方法是喚醒等待的線程.
方法notify()也要在同步方法或同步塊中調(diào)用,該方法是用來通知那些可能等待該對象的對象鎖的其它線程,對其發(fā)出通知notify,并使它們重新獲取該對象的對象鎖。
如果有多個線程等待,則有線程調(diào)度器隨機(jī)挑選出一個呈 wait 狀態(tài)的線程。(并沒有 “先來后到”)
在notify()方法后,當(dāng)前線程不會馬上釋放該對象鎖,要等到執(zhí)行notify()方法的線程將程序執(zhí)行完,也就是退出同步代碼塊之后才會釋放對象鎖。
注意事項(xiàng):
notify():隨機(jī)喚醒一個處在等待狀態(tài)的線程。
notifyAll():喚醒所有處在等待狀態(tài)的線程。
無論是wait還是notify方法,都需要搭配synchronized鎖來使用(等待和喚醒,也是需要對象)
四、關(guān)于wait和notify內(nèi)部等待問題(重要)
對于wait和notify方法,其實(shí)有一個阻塞隊列也有一個等待隊列。
阻塞隊列表示同一時間只有一個線程能獲取到鎖,其他線程進(jìn)入阻塞隊列
等待隊列表示調(diào)用wait (首先此線程要獲取到鎖,進(jìn)入等待隊列,釋放鎖)
舉個栗子:
現(xiàn)有如下定義的等待線程任務(wù)
privatestaticclassWaitTaskimplementsRunnable{ privateObjectlock; publicWaitTask(Objectlock){ this.lock=lock; } @Override publicvoidrun(){ synchronized(lock){ System.out.println(Thread.currentThread().getName()+"準(zhǔn)備進(jìn)入等待狀態(tài)"); //此線程在等待lock對象的notify方法喚醒 try{ lock.wait(); Thread.sleep(1000); }catch(InterruptedExceptione){ thrownewRuntimeException(e); } System.out.println(Thread.currentThread().getName()+"等待結(jié)束,本線程繼續(xù)執(zhí)行"); } } }
然后創(chuàng)建三個等待線程:
由于同一時間只有一個線程(隨機(jī)調(diào)度)能獲取到synchronized鎖,所以會有兩個線程沒競爭到鎖,從而進(jìn)入了阻塞隊列。
這里假如t2先競爭到了鎖,所以先會阻塞t1和t3:
又由于調(diào)用wait方法會釋放鎖,調(diào)用wait方法的線程t2就會進(jìn)入等待隊列,直到被notify喚醒或者超時自動喚醒。
然后此時lock對象已經(jīng)被釋放了,所以t1和t3 又可以去競爭這個鎖了,就從阻塞隊列里面競爭鎖。
這里假如t3 競爭到了鎖,阻塞隊列只剩下t1:
然后t3運(yùn)行到了wait方法,釋放鎖,然后進(jìn)入等待隊列:
然后重復(fù)這些操作~~,最后t1,t2,t3 都進(jìn)入了等待隊列中,等待notify線程喚醒(這里假設(shè)notify要放在這些線程start后的好幾秒后,因?yàn)閚otify線程也是和這些線程并發(fā)執(zhí)行的,所以等待隊列中的線程隨時可能被喚醒)
重點(diǎn)來了:
在等待隊列中的線程,被notify喚醒之后,會直接回到阻塞隊列去競爭鎖!!!而不是直接喚醒~
舉個栗子:
拿notifyAll()來舉例,假如此時等待隊列中有三個線程t1,t2,t3,那么調(diào)用notifyAll()會直接把它們?nèi)齻€直接從等待隊列中進(jìn)入到阻塞隊列中:
然后再去競爭這個鎖,去執(zhí)行wait之后的代碼~~
五、完整代碼(僅供測試用)
privatestaticclassWaitTaskimplementsRunnable{ privateObjectlock; publicWaitTask(Objectlock){ this.lock=lock; } @Override publicvoidrun(){ synchronized(lock){ System.out.println(Thread.currentThread().getName()+"準(zhǔn)備進(jìn)入等待狀態(tài)"); //此線程在等待lock對象的notify方法喚醒 try{ lock.wait(); Thread.sleep(1000); }catch(InterruptedExceptione){ thrownewRuntimeException(e); } System.out.println(Thread.currentThread().getName()+"等待結(jié)束,本線程繼續(xù)執(zhí)行"); } } } privatestaticclassNotifyTaskimplementsRunnable{ privateObjectlock; publicNotifyTask(Objectlock){ this.lock=lock; } @Override publicvoidrun(){ synchronized(lock){ System.out.println("準(zhǔn)備喚醒"); //喚醒所有線程(隨機(jī)) lock.notifyAll(); System.out.println("喚醒結(jié)束"); } } } publicstaticvoidmain(String[]args)throwsInterruptedException{ Objectlock=newObject(); Objectlock2=newObject(); //創(chuàng)建三個等待線程 Threadt1=newThread(newWaitTask(lock),"t1"); Threadt2=newThread(newWaitTask(lock),"t2"); Threadt3=newThread(newWaitTask(lock),"t3"); //創(chuàng)建一個喚醒線程 Threadnotify=newThread(newNotifyTask(lock2),"notify線程"); t1.start(); t2.start(); t3.start(); ; Thread.sleep(100); notify.start(); //當(dāng)前正在執(zhí)行的線程數(shù) Thread.sleep(2000); System.out.println(Thread.activeCount()-1); }
六、wait和sleep方法的區(qū)別(面試題):
wait方法是Object類提供的方法,需要搭配synchronized鎖來使用,調(diào)用wait方法會釋放鎖,線程進(jìn)入WAITING狀態(tài),等待被其他線程喚醒或者超時自動喚醒,喚醒之后的線程需要再次競爭synchronized鎖才能繼續(xù)執(zhí)行。
sleep方法是Thread類提供的方法,調(diào)用sleep方法的線程進(jìn)入TIMED_WAITING狀態(tài),不會釋放鎖,時間到自動喚醒。
總結(jié)
以上就是多線程場景下wait和notify方法的詳解和注意事項(xiàng)了,碼字不易,有幫助的話別忘了關(guān)注,點(diǎn)贊+收藏哦~
審核編輯:湯梓紅
-
JAVA
+關(guān)注
關(guān)注
20文章
2983瀏覽量
106498 -
多線程
+關(guān)注
關(guān)注
0文章
279瀏覽量
20243 -
代碼
+關(guān)注
關(guān)注
30文章
4880瀏覽量
69995 -
線程
+關(guān)注
關(guān)注
0文章
507瀏覽量
20019 -
WAIT
+關(guān)注
關(guān)注
0文章
4瀏覽量
2573
原文標(biāo)題:圖解 Java多線程中的 wait() 和 notify() 方法
文章出處:【微信號:AndroidPush,微信公眾號:Android編程精選】歡迎添加關(guān)注!文章轉(zhuǎn)載請注明出處。
發(fā)布評論請先 登錄
相關(guān)推薦
Java多線程的用法
Java中sleep和wait的區(qū)別
Java線程阻塞方法大全
Java的線程喚醒與阻塞規(guī)則
【java】兩種方式實(shí)現(xiàn)線程通信:三個線程交替打印AABBCC
java多線程編程實(shí)例 (源程序)
java多線程設(shè)計模式_結(jié)城浩

java多線程同步方法
分析在java中sleep和wait的不同
Java多線程總結(jié)之Queue

java學(xué)習(xí)——java面試【事務(wù)、鎖、多線程】資料整理
Java教程之零點(diǎn)起飛學(xué)Java的線程資料說明

評論