Question

CountDownLatch 允许一个或多个线程等待其他线程完成操作。

应用场景

假如有这样一个需求，当我们需要解析一个 Excel 里多个 sheet 的数据时，可以考虑使用多线程，每个线程解析一个 sheet 里的数据，等到所有 的 sheet 都解析完之后，程序需要提示解析完成。在这个需求中，要实现主线程等待所有线程完成 sheet 的解析操作，最简单的做法是使用 join。代码 如下：

public static void main(String[] args) throws InterruptedException {
    Thread t1=new
            Thread(() -> System.out.println(Thread.currentThread().getName()+" finish"));
    Thread t2=new 
            Thread(() -> System.out.println(Thread.currentThread().getName()+" finish"));
    t1.start();
    t2.start();
    t1.join();
    t2.join();
    System.out.println("所有线程执行完毕 主线程执行。。。。。。。。。。。。");       
}

输出：

Thread-0 finish
Thread-1 finish
所有线程执行完毕 主线程执行。。。。。。。。。。。。

• join 用于让当前执行线程等待 join 线程执行结束。其实现原理是不停检查 join 线程是否存活，如果 join 线程存活则让当前线程永远 wait
• 直到 join 线程中止后，线程的 this.notifyAll 会被调用，调用 notifyAll 是在 JVM 里实现的，所以 JDK 里看不到，可以看看 JVM 源码。JDK 不推荐在线程实例上使用 wait，notify 和 notifyAll 方法。

JDK1.5 之后的并发包中提供的 CountDownLatch 也可以实现 join 的这个功能，并且比 join 的功能更多

public class CountDownLatchTest {
    static CountDownLatch c=new CountDownLatch(2);
    public static void main(String[] args) throws InterruptedException {
        new Thread(() ->{
             System.out.println(1);
             c.countDown();
             System.out.println(2);
             c.countDown();
        }).start();
         c.await();
         System.out.println("3");
    }
}

CountDownLatch 的构造函数接收一个 int 类型的参数作为计数器，如果你想等待 N 个点完成，这里就传入 N。

• 当我们调用一次 CountDownLatch 的 countDown 方法时， N 就 会减 1，CountDownLatch 的 await 会阻塞当前线程，直到 N 变成零。由于 countDown 方法可以用在任何地方，所以这里说的 N 个点，可 以是 N 个线程，也可以是 1 个线程里的 N 个执行步骤。用在多个线程时，你只需要把这个 CountDownLatch 的引用传递到线程里。

其他方法

如果有某个解析 sheet 的线程处理的比较慢，我们不可能让主线程一直等待，所以我们可以使用另外一个带指定时间的 await 方法

这个方法等待特定时间后，就会不再阻塞当前线程。join 也有类似的方法。

await(long time, TimeUnit unit): 

• 注意：计数器必须大于等于 0，只是等于 0 时候，计数器就是零，调用 await 方法时不会阻塞当前线程。CountDownLatch 不可能重新初 始化或者修改 CountDownLatch 对象的内部计数器的值。一个线程调用 countDown 方法 happen-before 另外一个线程调用 await 方法。