CountDownLatch

public class CountDownLatch
extends Object

同步协助，允许一个或多个线程等待，直到在其他线程中执行的一组操作完成。

A CountDownLatch用给定的计数进行初始化。 await方法会阻塞，直到当前计数由于调用countDown()方法而达到零，此后所有等待的线程被释放，并且任何后续调用await立即返回。 这是一次性现象 - 计数无法重置。 如果您需要重置计数的版本，请考虑使用CyclicBarrier 。

A CountDownLatch是一款多功能同步工具，可用于多种用途。 一个CountDownLatch初始化为1的计数用作简单的开/关锁存器或门：调用await所有线程在门await等待，直到它被调用countDown()的线程打开countDown() 。 初始化为N的CountDownLatch可用于使一个线程等待，直到N个线程完成某个动作，或者某个动作已完成N次。

CountDownLatch一个有用的属性是它不需要调用 countDown线程在继续之前等待计数达到零，它只是阻止任何线程继续通过 await直到所有线程都可以通过。

示例用法：下面是一对类，其中一组工作线程使用两个倒计时锁存器：

• The first is a start signal that prevents any worker from proceeding until the driver is ready for them to proceed;
• The second is a completion signal that allows the driver to wait until all workers have completed.

 class Driver { // ...
   void main() throws InterruptedException {
     CountDownLatch startSignal = new CountDownLatch(1);
     CountDownLatch doneSignal = new CountDownLatch(N);

     for (int i = 0; i < N; ++i) // create and start threads
       new Thread(new Worker(startSignal, doneSignal)).start();

     doSomethingElse();            // don't let run yet
     startSignal.countDown();      // let all threads proceed
     doSomethingElse();
     doneSignal.await();           // wait for all to finish
   }
 }

 class Worker implements Runnable {
   private final CountDownLatch startSignal;
   private final CountDownLatch doneSignal;
   Worker(CountDownLatch startSignal, CountDownLatch doneSignal) {
     this.startSignal = startSignal;
     this.doneSignal = doneSignal;
   }
   public void run() {
     try {
       startSignal.await();
       doWork();
       doneSignal.countDown();
     } catch (InterruptedException ex) {} // return;
   }

   void doWork() { ... }
 }

另一个典型的用法是将问题分为N个部分，用Runnable来描述每个部分，该部分执行该部分并在锁存器上进行倒计数，并将所有Runnables排队到Executor。 当所有子部分完成时，协调线程将能够通过等待。 （当线程必须以这种方式重复倒数时，请使用CyclicBarrier ）

 class Driver2 { // ...
   void main() throws InterruptedException {
     CountDownLatch doneSignal = new CountDownLatch(N);
     Executor e = ...

     for (int i = 0; i < N; ++i) // create and start threads
       e.execute(new WorkerRunnable(doneSignal, i));

     doneSignal.await();           // wait for all to finish
   }
 }

 class WorkerRunnable implements Runnable {
   private final CountDownLatch doneSignal;
   private final int i;
   WorkerRunnable(CountDownLatch doneSignal, int i) {
     this.doneSignal = doneSignal;
     this.i = i;
   }
   public void run() {
     try {
       doWork(i);
       doneSignal.countDown();
     } catch (InterruptedException ex) {} // return;
   }

   void doWork() { ... }
 }

内存一致性影响：直到计数达到零为止，在调用 countDown() happen-before操作之前，线程中的操作 await()在另一个线程中对应的 await()成功返回 之后执行。

Summary

Inherited methods

From class java.lang.Object Object clone() 创建并返回此对象的副本。 boolean equals(Object obj) 指示其他某个对象是否“等于”这一个。 void finalize() 当垃圾收集确定没有更多对该对象的引用时，由对象上的垃圾回收器调用。 final Class<?> getClass() 返回此 Object的运行时类。 int hashCode() 返回对象的哈希码值。 final void notify() 唤醒正在等待该对象监视器的单个线程。 final void notifyAll() 唤醒在该对象监视器上等待的所有线程。 String toString() 返回对象的字符串表示形式。 final void wait(long millis, int nanos) 导致当前线程等待，直到另一个线程为该对象调用 notify()方法或 notifyAll()方法，或者某个其他线程中断当前线程，或者经过一定的实时时间。 final void wait(long millis) 导致当前线程等待，直到另一个线程调用此对象的 notify()方法或 notifyAll()方法或经过了指定的时间量。 final void wait() 使当前线程等待，直到另一个线程调用此对象的 notify()方法或 notifyAll()方法。

Public constructors

CountDownLatch (int count)

Public methods

void await ()

boolean await (long timeout, 
                TimeUnit unit)

void countDown ()

long getCount ()

String toString ()