CountDownLatch详解以及用法示例

一、什么是countDownlatch

CountDownLatch是一个同步工具类，它通过一个计数器来实现的,初始值为线程的数量。每当一个线程完成了自己的任务,计数器的值就相应得减1。当计数器到达0时,表示所有的线程都已执行完毕,然后在等待的线程就可以恢复执行任务。

二、方法详解

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

三、CountDownLatch应用场景

1. 某个线程需要在其他n个线程执行完毕后再向下执行2. 多个线程并行执行同一个任务，提高响应速度

四、CountDownLatch代码示例

public class CountDownLaunchTest {    public static void main(String[] args) throws InterruptedException {        List list = new ArrayList();        for(int i = 1; i<=100; i++){            list.add(i);        }        Long start = System.currentTimeMillis();        for(int i = 0; i<list.size(); i++){            Thread.sleep(100);        }        System.out.println("=====同步执行：耗时"+(System.currentTimeMillis()-start)+"毫秒======");        Long start1 = System.currentTimeMillis();        CountDownLatch latch = new CountDownLatch(10);        for(int i = 0; i<latch.getCount(); i++){            new Thread(new Test(latch, i, list)).start();        }        latch.await();        System.out.println("=====异步执行：耗时"+(System.currentTimeMillis()-start1)+"毫秒======");    }    static class Test implements Runnable{        private CountDownLatch latch;        private int i;        private List list;        Test(CountDownLatch latch, int i, List list){            this.latch = latch;            this.i = i;            this.list = list;        }        @SneakyThrows        @Override        public void run() {            for(int a = i*10; a<(i+1)*10; a++){                // 执行任务逻辑                Thread.sleep(100);            }            latch.countDown();        }    }}

执行结果：

注：如果多个线程并行执行一个任务，则初始count值必须与启动线程数保持一致，即count为10，则必须开启10 个异步线程

来源地址：https://blog.csdn.net/liu_da_da/article/details/124983187