CountDownLatch 可以立即看作一個計數器，不過計數是原子操作，也就是說同一時間只有一個線程能夠操作該計數器；

我們先看看該類常用的幾個方法：

你可以給它設定一個數目，調用該類await方法會使調用await的方法的線程處于等待狀態；直到該計數器計數為0；由此特性，我們可以將它用于一下場景：

場景：只有把所有的任務執行完畢后才執行另外一個任務

下面演示是當把三個WorkTask任務都執行完畢后才執行AllTaskDonedTask任務

public class Test{public static void main(String[] args) {int taskSize = 3;//創建一個計數器，并對其初始化final CountDownLatch doneSingle = new CountDownLatch(taskSize);//創建一個固定線程池,此處線程池的線程數目和taskSize無直接關Executor executor = Executors.newFixedThreadPool(taskSize);//執行所有任務for (int i = 0; i < taskSize; i++) {executor.execute(new WorkTask(doneSingle));}executor.execute(new AllTaskDonedTask(countDownLatch));}static class WorkTask implements Runnable {CountDownLatch mCountDownLatch;public WorkTask(CountDownLatch countDownLatch) {mCountDownLatch = countDownLatch;}@Overridepublic void run() {try {println(Thread.currentThread().getName()+" execute task....");Thread.sleep(1000);//模擬耗時操作mCountDownLatch.countDown();//任務執行完畢計數器減1} catch (InterruptedException e) {e.printStackTrace();}}}//所有任務執行完畢后需要執行的任務static class AllTaskDonedTask implements Runnable {CountDownLatch mCountDownLatch;public AllTaskDonedTask(CountDownLatch countDownLatch) {mCountDownLatch = countDownLatch;}@Overridepublic void run() {try {mCountDownLatch.await();//此處會使當前線程處于等待狀態，直到3個WorkTask全部執行完畢，才會繼續執行下面println("所有任務執行完畢我才執行");} catch (InterruptedException e) {e.printStackTrace();}}}}

執行結果：

pool-1-thread-3 execute task.... pool-1-thread-1 execute task.... pool-1-thread-2 execute task.... 所有任務執行完畢我才執行

從上面代碼我們不難看出，我們在執行WorkTask任務結束時都需要對計數器減1；在AllTaskDonedTask任務執行前需要調用CountDownLatch.await()方法，這樣當前線程會處于等待狀態，直到計數器減為0時也即WorkTask任務都執行完畢后，AllTaskDonedTask方可執行。

總結

以上是生活随笔為你收集整理的Java多线程-CountDownLatch用法的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。