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

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

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

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

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

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



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

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

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

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

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