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方法。