java 并發(fā)工具類CountDownLatch & CyclicBarrier

一起在java1.5被引入的并發(fā)工具類還有CountDownLatch、CyclicBarrier、Semaphore、ConcurrentHashMap和BlockingQueue，它們都存在于java.util.concurrent包下。

CountDownLatch

CountDownLatch 概念

CountDownLatch這個類能夠使一個線程等待其他線程完成各自的工作后再執(zhí)行。例如，應(yīng)用程序的主線程希望在負責(zé)啟動框架服務(wù)的線程已經(jīng)啟動所有的框架服務(wù)之后再執(zhí)行。

CountDownLatch是通過一個計數(shù)器來實現(xiàn)的，計數(shù)器的初始值為線程的數(shù)量。每當(dāng)一個線程完成了自己的任務(wù)后，計數(shù)器的值就會減1。當(dāng)計數(shù)器值到達0時，它表示所有的線程已經(jīng)完成了任務(wù)，然后在閉鎖上等待的線程就可以恢復(fù)執(zhí)行任務(wù)。

圖示：

偽代碼：

//Main thread start//Create CountDownLatch for N threads
//Create and start N threads
//Main thread wait on latch
//N threads completes there tasks are returns//Main thread resume execution

CountDownLatch 如何工作

CountDownLatch.java類中定義的構(gòu)造函數(shù)：

        		
網(wǎng)友評論