怎么實(shí)現(xiàn)所有線程在等待某個(gè)事件的發(fā)生才會(huì)去執(zhí)行?

java里面實(shí)現(xiàn)這個(gè)有兩個(gè)辦法,countdownlatch和cyclicbarrier。

cyclicbarrier可以重復(fù)使用,它允許一組線程相互等待,直到達(dá)到某個(gè)公共屏障點(diǎn)。cyclicbarrier不會(huì)阻塞主線程,只會(huì)阻塞子線程。

countdownlatch不可以重復(fù)使用,會(huì)阻塞主線程。主線程調(diào)用await方法,主線程阻塞。子線程調(diào)用countdown方法,觸發(fā)計(jì)數(shù)。countdownlatch內(nèi)部是實(shí)現(xiàn)了AQS,初始化的時(shí)候,new? CountDownLatch(n);將AQS的state設(shè)置為n。

await方法->acquireSharedInterruptibly->doAcquireSharedInterruptibly->shouldParkAfterFailedAcquire&parkAndCheckInterrupt->LockSupport.park.根據(jù)此調(diào)用鏈,會(huì)將當(dāng)前線程阻塞。shouldParkAfterFailedAcquire方法相當(dāng)于重新構(gòu)造阻塞隊(duì)列,對(duì)于前驅(qū)節(jié)點(diǎn)的waitstate大于0的刪除,不是SIGNAL的賦值為SIGNAL。

countdown是個(gè)解鎖的過(guò)程,每個(gè)子線程執(zhí)行一次countdown,state就減一,state等于0時(shí),就會(huì)執(zhí)行如下代碼



unparkSuccessor方法的參數(shù)是頭結(jié)點(diǎn),此時(shí)的隊(duì)列應(yīng)該是只有一個(gè)等待節(jié)點(diǎn),就是主線程。s不等于null,s是主線程。

cyclicbarrier內(nèi)部使用Lock,每一個(gè)子線程執(zhí)行await,計(jì)數(shù)減一,當(dāng)最后一個(gè)子線程的計(jì)數(shù)為0時(shí),會(huì)執(zhí)行cyclicbarrier構(gòu)造函數(shù)中的Runable參數(shù)的run方法。

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時(shí)請(qǐng)結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點(diǎn),簡(jiǎn)書(shū)系信息發(fā)布平臺(tái),僅提供信息存儲(chǔ)服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容