Java中的CountDownLatch简单理解
更新时间：2024年01月17日 09:57:14 作者：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简单理解内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
Java中的ScheduledThreadPoolExecutor定时任务详解
这篇文章主要介绍了Java中的ScheduledThreadPoolExecutor详解, ScheduledThreadPoolExecutor 继承自 ThreadPoolExecutor,它主要用来在给定的延迟之后运行任务,或者定期执行任务,ScheduledThreadPoolExecutor 的功能与 Timer 类似<BR>,需要的朋友可以参考下2023-12-12
这篇文章主要给大家介绍了关于Java如何优雅的实现微信登录注册的相关资料,文中通过实例代码介绍的非常详细,对大家学习或者使用java具有一定的参考学习价值,需要的朋友可以参考下2022-02-02
这篇文章主要为大家详细介绍了Java简易聊天室之实现客户端群聊功能，文中的示例代码讲解详细，具有一定的借鉴价值，需要的可以了解一下2022-10-10
最小生成树（MST）指在连通图的所有生成树中，所有边的权值和最小的生成树。本文介绍了求最小生成树的两种方法：Prim算法和Kruskal算法，需要的可以参考一下2022-05-05
这篇文章主要为大家介绍了Reactor3 Map与FlatMap的区别示例详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪2023-08-08
本文主要介绍了springboot3生成本地文件url的实现示例,从而提供一种高效的文件管理方式,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧2024-01-01
JPA（Java Persistence API）是Java提供的一套数据持久化标准,通过对象-关系映射（ORM）技术实现Java对象与数据库表之间的映射,它提供了一系列注解和接口,简化了数据库操作,使得开发者可以通过操作对象来进行数据库交互,而无需编写复杂的SQL语句2024-10-10
这篇文章主要介绍了SpringBoot如何接收前端传来的json数据问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2023-04-04
这篇文章主要介绍了Java图形界面GUI布局方式(小结)，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2021-04-04
Java中的DelayQueue是一个特殊的队列,它只允许在指定的延迟时间之后才能从队列中取出元素,这篇文章主要给大家介绍了关于Java实现DelayQueue延迟队列的相关资料,需要的朋友可以参考下2025-07-07
最新评论