CountDownLatch简单理解

一、什么是CountDownLatch

CountDownLatch是一个同步工具类，用来携调多个线程之间的同步，它是是使用一个计数器进行实现的，计数器初始值为线程数量。当每一个线程完成自己任务后，计数器的值就会减1。当计数器的值为0时，表示所有的线程都已经完成一些任务，然后再CountDownLatch上等待的线程就可以恢复执行下来的任务。

二、哪些场景使用CountDownLatch

使用场景

三、CountDownLatch常用的方法

• new CountDownLatch(int count):count为计数器的初始值(一般需要多少个先吃执行，count就设置为几)
• countDown():每调用一次计数器值-1，直到count被减为0，代表所有线程全部执行完毕。
• getCount():获取当前的计数器值。
• await():等待计数器变为0，即等待所有的异步线程执行完毕
• boolean await(long timeout,TimeUnit unit):此方法至多会等待指定的时间，然后超时会自动唤醒，若timeout小于等于0，则不会等待。当计数器变为0，则返回true。若指定的等待时间过去了，则返回false。

四、CountDownLatch使用案例

线程池+CountDownLatch

线程池代码:线程池工具类_java-zh的博客-CSDN博客

public class Test {
    public static void main(String[] args) throws InterruptedException {
        //当前执行的线程数量
        Integer poolNum = 10;
        long start = System.currentTimeMillis();
        //初始化线程运行的数量
        CountDownLatch countDownLatch = new CountDownLatch(poolNum);
        Map<Integer,Integer> map = new HashMap<>();
        for (int i = 1; i <= poolNum; i++) {
            //耗时
            Integer time = i*1000;
            ThreadPoolUtils.execute(()->{
                try {
                    //假设逻辑执行的耗时
                    Thread.sleep(time);
                    map.put(time,time);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }finally {
                    countDownLatch.countDown();
                }

            });
        }
        countDownLatch.await();
        System.out.println("总耗时:"+(System.currentTimeMillis()-start));
        for (Integer key: map.keySet()){
            //打印出来的key值是没有顺序的，因为竞争的CPU资源不一样
            System.out.println("map的key为:"+key+" map的值为:"+ map.get(key));
        }
    }
}