Java中的CountDownLatch简单理解
作者：java-zh
这篇文章主要介绍了Java中的CountDownLatch简单理解,CountDownLatch是一个同步工具类,用来携调多个线程之间的同步,它是是使用一个计数器进行实现的,计数器初始值为线程数量,需要的朋友可以参考下
一、什么是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
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));
}
}
}到此这篇关于Java中的CountDownLatch简单理解的文章就介绍到这了,更多相关CountDownLatch简单理解内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！