該方法先是?CAS?修改了節(jié)點(diǎn)狀態(tài)，如果成功，就將這個(gè)節(jié)點(diǎn)放到?AQS?隊(duì)列中，然后喚醒這個(gè)節(jié)點(diǎn)上的線程。此時(shí)，那個(gè)節(jié)點(diǎn)就會(huì)在?await?方法中蘇醒

final boolean transferForSignal(Node node) { if (!compareAndSetWaitStatus(node, Node.CONDITION, 0))//更新節(jié)點(diǎn)的狀態(tài)為0，如果更新失敗，只有一種可能就是節(jié)點(diǎn)被CANCELLED了 return false; Node p = enq(node);//調(diào)用enq，把當(dāng)前節(jié)點(diǎn)添加到AQS隊(duì)列。并且返回返回按當(dāng)前節(jié)點(diǎn)的上一個(gè)節(jié)點(diǎn)，也就是原tail節(jié)點(diǎn) int ws = p.waitStatus; // 如果上一個(gè)節(jié)點(diǎn)的狀態(tài)被取消了, 或者嘗試設(shè)置上一個(gè)節(jié)點(diǎn)的狀態(tài)為 SIGNAL 失敗了(SIGNAL 表示: 他的 next節(jié)點(diǎn)需要停止阻塞), if (ws > 0 || !compareAndSetWaitStatus(p, ws, Node.SIGNAL)) LockSupport.unpark(node.thread); // 喚醒節(jié)點(diǎn)上的線程. return true; //如果node的prev節(jié)點(diǎn)已經(jīng)是signal狀態(tài)，那么被阻塞的ThreadA的喚醒工作由AQS隊(duì)列來完成 }

圖解分析

執(zhí)行完doSignal以后，會(huì)把condition隊(duì)列中的節(jié)點(diǎn)轉(zhuǎn)移到aqs隊(duì)列上，邏輯結(jié)構(gòu)圖如下

這個(gè)時(shí)候會(huì)判斷ThreadA的prev節(jié)點(diǎn)也就是head節(jié)點(diǎn)的waitStatus，如果大于0或者設(shè)置SIGNAL失敗，表示節(jié)點(diǎn)被設(shè)置成了CANCELLED狀態(tài)。這個(gè)時(shí)候會(huì)喚醒ThreadA這個(gè)線程。否則就基于AQS隊(duì)列的機(jī)制來喚醒，也就是等到ThreadB釋放鎖之后來喚醒ThreadA

?

超強(qiáng)干貨來襲 云風(fēng)專訪：近40年碼齡，通宵達(dá)旦的技術(shù)人生

總結(jié)

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

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