調(diào)用Condition的await()方法（或者以await開頭的方法），會使當(dāng)前線程進(jìn)入等待隊列并釋放鎖，同時線程狀態(tài)變?yōu)榈却隣顟B(tài)。當(dāng)從await()方法返回時，當(dāng)前線程一定獲取了Condition相關(guān)聯(lián)的鎖

public final void await() throws InterruptedException { if (Thread.interrupted()) //表示await允許被 中斷 throw new InterruptedException(); Node node = addConditionWaiter(); //創(chuàng)建一個 新的節(jié)點，節(jié)點狀態(tài)為condition，采用的數(shù)據(jù)結(jié)構(gòu)仍然是鏈表 int savedState = fullyRelease(node); //釋放當(dāng)前的鎖，得到鎖的狀態(tài)，并喚醒AQS隊列中的一個線程 int interruptMode = 0; //如果當(dāng)前節(jié)點沒有在同步隊列上，即還沒有被signal，則將當(dāng)前線程阻塞 while (!isOnSyncQueue(node)) {//判斷這個節(jié)點是否在AQS隊列上，第一次判斷的是false，因為前面已經(jīng)釋放鎖了 LockSupport.park(this); //通過park掛起當(dāng)前線程 if ((interruptMode = checkInterruptWhileWaiting(node)) != 0) break; } // 當(dāng)這個線程醒來,會嘗試拿鎖, 當(dāng) acquireQueued 返回 false 就是拿到鎖了. // interruptMode != THROW_IE -> 表示這個線程沒有成功將 node 入隊,但 signal 執(zhí)行了 enq 方法讓其入隊了. // 將這個變量設(shè)置成 REINTERRUPT. if (acquireQueued(node, savedState) && interruptMode != THROW_IE) interruptMode = REINTERRUPT; // 如果 node 的下一個等待者不是 null, 則進(jìn)行清理,清理 Condition 隊列上的節(jié)點. // 如果是 null ,就沒有什么好清理的了. if (node.nextWaiter != null) // clean up if cancelled unlinkCancelledWaiters(); // 如果線程被中斷了,需要拋出異常.或者什么都不做 if (interruptMode != 0) reportInterruptAfterWait(interruptMode); }

?

總結(jié)

以上是生活随笔為你收集整理的condition.await的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。