快捷導(dǎo)航

java并發(fā)編程專題（八）----（JUC）實例講解CountDownLatch

更新時間：2020年07月02日 11:02:49 作者：rickiyang

這篇文章主要介紹了java CountDownLatch的相關(guān)資料，文中示例代碼非常詳細，幫助大家理解和學(xué)習(xí)，感興趣的朋友可以了解下

CountDownLatch 是一個非常實用的多線程控制工具類?！?Count Down ” 在英文中意為倒計數(shù)， Latch 為門問的意思。如果翻譯成為倒計數(shù)門閥，我想大家都會覺得不知所云吧! 因此，這里簡單地稱之為倒計數(shù)器。在這里，門問的含義是:把門鎖起來，不讓里面的線程跑出來。因此，這個工具通常用來控制線程等待，它可以讓某一個線程等待直到倒計時結(jié)束，再開始執(zhí)行。

CountDown Latch 的構(gòu)造函數(shù)接收一個整數(shù)作為參數(shù)，即當前這個計數(shù)器的計數(shù)個數(shù)。

public CountDownLatch(int count)

CountDownLatch是一個同步輔助類，在完成一組正在其他線程中執(zhí)行的操作之前，它允許一個或多個線程一直等待。一個CountDownLatch初始化為給定的計數(shù) 。調(diào)用await方法阻塞，直到當前計數(shù)為零，在調(diào)用countDown()方法之后，所有等待的線程被釋放，任何后續(xù)調(diào)用await立即返回。這是一次性的現(xiàn)象 - 計數(shù)不能重置。如果需要重置計數(shù)，考慮使用CyclicBarrier ，CyclicBarrier的計數(shù)器可以被重置后使用，因此它被稱為是循環(huán)的barrier。

主要方法：

// 使當前線程在鎖存器倒計數(shù)至零之前一直等待，除非線程被中斷。
void await()
// 使當前線程在鎖存器倒計數(shù)至零之前一直等待，除非線程被中斷或超出了指定的等待時間。
boolean await(long timeout, TimeUnit unit)
// 遞減鎖存器的計數(shù)，如果計數(shù)到達零，則釋放所有等待的線程。
void countDown()
// 返回當前計數(shù)。
long getCount()

我們來看一個例子：

public class TestCountDownLatch {
  private static final int RUNNER_NUMBER = 5; // 運動員個數(shù)
  private static final Random RANDOM = new Random();
  public static void main(String[] args) {
    // 用于判斷發(fā)令之前運動員是否已經(jīng)完全進入準備狀態(tài)，需要等待5個運動員，所以參數(shù)為5
    CountDownLatch readyLatch = new CountDownLatch(RUNNER_NUMBER);
    // 用于判斷裁判是否已經(jīng)發(fā)令，只需要等待一個裁判，所以參數(shù)為1
    CountDownLatch startLatch = new CountDownLatch(1);
    for (int i = 0; i < RUNNER_NUMBER; i++) {
      Thread t = new Thread(new Runner((i + 1) + "號運動員", readyLatch, startLatch));
      t.start();
    }
    try {
      readyLatch.await();
    } catch (InterruptedException e) {
      e.printStackTrace();
    }
    startLatch.countDown();
    System.out.println("裁判：所有運動員準備完畢，開始...");
  }
  static class Runner implements Runnable {
    private CountDownLatch readyLatch;
    private CountDownLatch startLatch;
    private String name;
    public Runner(String name, CountDownLatch readyLatch, CountDownLatch startLatch) {
      this.name = name;
      this.readyLatch = readyLatch;
      this.startLatch = startLatch;
    }
    public void run() {
      int readyTime = RANDOM.nextInt(1000);
      System.out.println(name + "：我需要" + readyTime + "秒時間準備.");
      try {
        Thread.sleep(readyTime);
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
      System.out.println(name + "：我已經(jīng)準備完畢.");
      readyLatch.countDown();
      try {
        startLatch.await(); // 等待裁判發(fā)開始命令
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
      System.out.println(name + "：開跑...");
    }
  }
}

打印結(jié)果：

1號運動員：我需要547秒時間準備.
2號運動員：我需要281秒時間準備.
4號運動員：我需要563秒時間準備.
5號運動員：我需要916秒時間準備.
3號運動員：我需要461秒時間準備.
2號運動員：我已經(jīng)準備完畢.
3號運動員：我已經(jīng)準備完畢.
1號運動員：我已經(jīng)準備完畢.
4號運動員：我已經(jīng)準備完畢.
5號運動員：我已經(jīng)準備完畢.
裁判：所有運動員準備完畢，開始...
3號運動員：開跑...
2號運動員：開跑...
1號運動員：開跑...
4號運動員：開跑...
5號運動員：開跑...

Process finished with exit code 0