1、概述

CountDownLatch是一个同步器工具类，用来协调多个线程之间的同步，能够使一个线程在等待另外一些线程完成各自工作之后，再继续执行，不可重置使用。

2、实现

使用一个计数器进行实现，计数器初始值为线程的数量，当每一个线程完成自己任务后，计数器的值就会减一，当计数器的值为0时，在CountDownLatch上等待的线程就可以恢复执行接下来的任务。

3、缺点

CountDownLatch是一次性的，计算器的值只能在构造方法中初始化一次，之后没有任何机制再次对其设置值，当CountDownLatch使用完毕后，它不能再次被使用。

4、方法说明：

public void countDown()：递减锁存器的计数，如果计数到达零，则释放所有等待的线程。如果当前计数大于零，则将计数减少.
public viod await() /boolean await(long timeout,TimeUnit unit) ：使当前线程在锁存器倒计数至零之前一直等待，除非线程被中断或超出了指定的等待时间。如果当前计数为零，则此方法立刻返回true值。当线程调用了CountDownLatch对象的该方法后，当前线程会被阻塞,直到下面的情况之一发生才会返回：
- 如果计数到达零，则该方法返回true值。
- 如果当前线程，在进入此方法时已经设置了该线程的中断状态；或者在等待时被中断，则抛出InterruptedException，并且清除当前线程的已中断状态。
- 如果超出了指定的等待时间，则返回值为false。如果该时间小于等于零，则该方法根本不会等待。参数：timeout-要等待的最长时间、unit-timeout 参数的时间单位

5、使用用法

某一线程在开始运行前等待n个线程执行完毕
多个线程开始执行任务的最大并行性(多个线程等待一个线程执行完成)

5.1 方法一

某一线程在开始运行前等待n个线程执行完毕，为某一个线程设置await()，当CountDownLatch为0时，执行当前线程。

public class Test {
    /**
     * 设置计数器大小为5
     */
    private static CountDownLatch latch = new CountDownLatch(5);

    public static void loading(int num) {
        System.out.println("计数器数量为：" + num);
        try {
            TimeUnit.SECONDS.sleep(1);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        latch.countDown();
    }

    public static void main(String[] args) {
        new Thread(() -> {
            for (int i = 5; i >= 1; i--) {
                loading(i);
            }
        }, "t1").start();


        // 等待5个t1线程执行完成
        try {
            latch.await();
            System.out.println("执行主线程");
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

效果：

5.2 方法二

实现多个线程开始执行任务的最大并行性，比如设置CountDownLatch()初始化值为1，多个线程同时进行countdownlatch.await()，到计数器值为0时多个线程同时运行(多个线程等待其他线程执行完成后再执行)。

public class Test {
    /**
     * 设置计数器大小为1
     */
    private static CountDownLatch latch = new CountDownLatch(1);

    public static void main(String[] args) {
        for (int i = 5; i >= 1; i--) {
            new Thread(() -> {
                try {
                    System.out.println(Thread.currentThread().getName() + "-准备中");
                    latch.await();
                    System.out.println(Thread.currentThread().getName() + "-已完成");
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }).start();
        }

        // 等待一秒，让其他线程做好准备
        try {
            TimeUnit.SECONDS.sleep(1);
            System.out.println("执行主线程");
            latch.countDown();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}