一、什么是CountDownLatch
CountDownLatch是一个同步工具类,用来携调多个线程之间的同步,它是是使用一个计数器进行实现的,计数器初始值为线程数量。当每一个线程完成自己任务后,计数器的值就会减1。当计数器的值为0时,表示所有的线程都已经完成一些任务,然后再CountDownLatch上等待的线程就可以恢复执行下来的任务。
二、哪些场景使用CountDownLatch
使用场景
- 某个线程需要在其他n个线程执行完毕后再往下执行。将CountDownLatch的计算器初始化化为new CountDownLatch(n),每当一个线程任务执行完毕,就将计数器减一(countDownLatch.countDown()),当计数器变为0的时候,在CountDownLatch上的线程就会被唤醒 。比如,启动一个服务时,主线程要等待多个组件加载完毕,之后在继续执行。
- 多个线程并行执行同一个任务,提高响应速度。注意时并行,不是并发,强调的是多个线程在某一时刻同时开始执行。类似于赛跑,将多个线程放到起点,等待起跑,然后同时开跑。做法是初始化一个共享的CountDownLatch(1),将其计数器初始化为1,多个线程在开始执行任务前首先countDownLatch.await(),当主线程调用countDown()时,计数器为0,多个线程同时被唤醒。
三、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));}}
}