建站
咨詢(xún)
售后
建站咨詢(xún)
新聞中心
簡(jiǎn)單介紹
- wait方法
wait方法的作用是使當(dāng)前執(zhí)行代碼的線(xiàn)程進(jìn)行等待，它是Object類(lèi)的方法，該方法用來(lái)將當(dāng)前線(xiàn)程置入等待隊(duì)列中，并且在wait所在的代碼行處停止執(zhí)行，直到接到通知或被中斷為止。
成都創(chuàng)新互聯(lián)一直通過(guò)網(wǎng)站建設(shè)和網(wǎng)站營(yíng)銷(xiāo)幫助企業(yè)獲得更多客戶(hù)資源。 以"深度挖掘，量身打造，注重實(shí)效"的一站式服務(wù)，以成都網(wǎng)站制作、成都做網(wǎng)站、移動(dòng)互聯(lián)產(chǎn)品、成都營(yíng)銷(xiāo)網(wǎng)站建設(shè)服務(wù)為核心業(yè)務(wù)。10余年網(wǎng)站制作的經(jīng)驗(yàn)，使用新網(wǎng)站建設(shè)技術(shù)，全新開(kāi)發(fā)出的標(biāo)準(zhǔn)網(wǎng)站，不但價(jià)格便宜而且實(shí)用、靈活，特別適合中小公司網(wǎng)站制作。網(wǎng)站管理系統(tǒng)簡(jiǎn)單易用，維護(hù)方便，您可以完全操作網(wǎng)站資料，是中小公司快速網(wǎng)站建設(shè)的選擇。
該方法只能在同步方法或同步塊中調(diào)用(即需要先獲得對(duì)象的監(jiān)視器鎖，一般來(lái)說(shuō)在 synchronized 代碼塊或者synchronized修飾的方法中使用)，否則拋出異常
IllegalMonitorStateException。
在A線(xiàn)程中調(diào)用Lock對(duì)象的wait方法以后，會(huì)釋放Lock對(duì)象的監(jiān)視器鎖，同時(shí)將A線(xiàn)程放置于Lock對(duì)象的等待隊(duì)列，A線(xiàn)程進(jìn)入WAITING狀態(tài)(Thread狀態(tài)查看系列一)。
- notify/notifyAll方法
notify/notifyAll方法的作用是喚醒執(zhí)行對(duì)象的等待列表中的一個(gè)/所有線(xiàn)程，將其喚醒繼續(xù)工作。
同樣的，notify/notifyAll方法也只能在同步方法或同步塊中調(diào)用，即在調(diào)用前，線(xiàn)程也必須獲得該對(duì)象的監(jiān)視器鎖。
在B線(xiàn)程中調(diào)用Lock對(duì)象的notify/notifyAll方法以后，Lock對(duì)象等待隊(duì)列中的A線(xiàn)程從WAITING狀態(tài)進(jìn)入BLOCKED狀態(tài)，而不是直接進(jìn)入RUNNABLE狀態(tài)。只有等B線(xiàn)程釋放了Lock對(duì)象的監(jiān)視器鎖，并且A線(xiàn)程拿到以后，才進(jìn)入到RUNNABLE狀態(tài)。所以在編程中，盡量在使用了notify/notifyAll() 后立即釋放對(duì)象的監(jiān)視器鎖，以便讓其他線(xiàn)程獲得鎖進(jìn)入RUNNABLE狀態(tài)。
- 其他注意事項(xiàng)
wait、notify/notifyAll 方法是Object的本地final方法，無(wú)法被重寫(xiě)。
notify 和wait 的順序不能錯(cuò)，如果A線(xiàn)程先執(zhí)行notify方法，B線(xiàn)程再執(zhí)行wait方法，那么B線(xiàn)程是無(wú)法被喚醒的。
實(shí)例詳解
- public class WaitThread extends Thread {
- private Object lock;
- public WaitThread(Object lock) {
- this.lock = lock;
- }
- @Override
- public void run() {
- synchronized (lock) {
- System.out.println("WaitThread開(kāi)始執(zhí)行run方法");
- try {
- System.out.println("WaitThread開(kāi)始執(zhí)行wait方法");
- lock.wait();
- System.out.println("WaitThread被喚醒");
- } catch (InterruptedException e) {
- e.printStackTrace();
- }
- }
- }
- }
- public class NotifyThread extends Thread {
- private Object lock;
- public NotifyThread(Object lock) {
- this.lock = lock;
- }
- @Override
- public void run() {
- System.out.println("NotifyThread開(kāi)始執(zhí)行run方法");
- try {
- System.out.println("NotifyThread睡眠2秒");
- Thread.sleep(2000);
- } catch (InterruptedException e) {
- e.printStackTrace();
- }
- synchronized (lock) {
- System.out.println("NotifyThread開(kāi)始執(zhí)行notify方法");
- lock.notify();
- try {
- System.out.println("NotifyThread執(zhí)行notify方法后繼續(xù)睡眠2秒");
- Thread.sleep(2000);
- } catch (InterruptedException e) {
- e.printStackTrace();
- }
- System.out.println("NotifyThread睡眠2秒結(jié)束，并釋放對(duì)象監(jiān)視器鎖");
- }
- }
- }
- public class Main {
- public static void main(String[] args) {
- Object lock = new Object();
- // 創(chuàng)建2個(gè)線(xiàn)程
- WaitThread waitThread = new WaitThread(lock);
- NotifyThread notifyThread = new NotifyThread(lock);
- // 啟動(dòng)他們
- waitThread.start();
- notifyThread.start();
- }
- }
- NotifyThread開(kāi)始執(zhí)行run方法
- WaitThread開(kāi)始執(zhí)行run方法
- WaitThread開(kāi)始執(zhí)行wait方法
- NotifyThread睡眠2秒
- NotifyThread開(kāi)始執(zhí)行notify方法
- NotifyThread執(zhí)行notify方法后繼續(xù)睡眠2秒
- NotifyThread睡眠2秒結(jié)束，并釋放對(duì)象監(jiān)視器鎖
- WaitThread被喚醒
WaitThread在拿到lock的監(jiān)視器鎖以后調(diào)用wait方法。
NotifyThread在啟動(dòng)以后先睡眠2秒，保證了notify方法在wait方法后面。
NotifyThread執(zhí)行notify方法后繼續(xù)睡眠2秒，這個(gè)時(shí)候NotifyThread并沒(méi)有釋放Lock的監(jiān)視器鎖，因此WaitThread處于BLOCKED狀態(tài)并沒(méi)有被真正被喚醒。
NotifyThread睡眠2秒結(jié)束，并釋放對(duì)象監(jiān)視器鎖，這個(gè)時(shí)候NotifyThread取到Lock的監(jiān)視器鎖并進(jìn)入到RUNNABLE狀態(tài)。
進(jìn)階思考
如果A線(xiàn)程獲得了多個(gè)對(duì)象的監(jiān)視器鎖，然后調(diào)用其中1個(gè)對(duì)象的wait方法，是釋放所有對(duì)象的鎖還是只釋放調(diào)用的那個(gè)對(duì)象的鎖呢?
我們一起通過(guò)一個(gè)示例來(lái)進(jìn)行一下測(cè)試。
- public class WaitThread extends Thread {
- private Object lock;
- private Object other;
- public WaitThread(Object lock, Object other) {
- this.lock = lock;
- this.other = other;
- }
- @Override
- public void run() {
- synchronized (lock) {
- synchronized (other) {
- System.out.println("WaitThread開(kāi)始執(zhí)行run方法");
- try {
- System.out.println("WaitThread開(kāi)始執(zhí)行wait方法");
- lock.wait();
- System.out.println("WaitThread被喚醒");
- } catch (InterruptedException e) {
- e.printStackTrace();
- }
- }
- }
- }
- }
- public class NotifyThread extends Thread {
- private Object lock;
- private Object other;
- public NotifyThread(Object lock, Object other) {
- this.lock = lock;
- this.other = other;
- }
- @Override
- public void run() {
- System.out.println("NotifyThread開(kāi)始執(zhí)行run方法");
- try {
- System.out.println("NotifyThread睡眠2秒");
- Thread.sleep(2000);
- } catch (InterruptedException e) {
- e.printStackTrace();
- }
- synchronized (lock) {
- System.out.println("NotifyThread獲得lock鎖");
- synchronized (other) {
- System.out.println("NotifyThread獲得other鎖");
- System.out.println("NotifyThread開(kāi)始執(zhí)行notify方法");
- lock.notify();
- try {
- System.out.println("NotifyThread執(zhí)行notify方法后繼續(xù)睡眠2秒");
- Thread.sleep(2000);
- } catch (InterruptedException e) {
- e.printStackTrace();
- }
- System.out.println("NotifyThread睡眠2秒結(jié)束，并釋放對(duì)象監(jiān)視器鎖");
- }
- }
- }
- }
- public class Main {
- public static void main(String[] args) {
- Object lock = new Object();
- Object other = new Object();
- // 創(chuàng)建2個(gè)線(xiàn)程
- WaitThread waitThread = new WaitThread(lock, other);
- NotifyThread notifyThread = new NotifyThread(lock, other);
- // 啟動(dòng)他們
- waitThread.start();
- notifyThread.start();
- }
- }
- WaitThread開(kāi)始執(zhí)行run方法
- WaitThread開(kāi)始執(zhí)行wait方法
- NotifyThread開(kāi)始執(zhí)行run方法
- NotifyThread睡眠2秒
- NotifyThread獲得lock鎖
WaitThread線(xiàn)程拿到lock和other的對(duì)象鎖以后，執(zhí)行了lock的wait方法。NotifyThread線(xiàn)程在睡眠2秒后，僅拿到了lock鎖，說(shuō)明wait方法只釋放了被執(zhí)行對(duì)應(yīng)的鎖，這樣就造成了死鎖。
因此如果使用wait和notify機(jī)制時(shí)，一定要確認(rèn)Wait線(xiàn)程和Notify線(xiàn)程獲取對(duì)象鎖的情況，盡量避免在獲取多個(gè)對(duì)象鎖的情況下使用，防止造成死鎖問(wèn)題。
分享文章：Java并發(fā)編程之二徹底理解Java的wait和Notify機(jī)制
URL鏈接：http://www.dlmjj.cn/article/djosgie.html
