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