java使用CountDownLatch等待多线程全部执行完成
更新时间：2018年10月15日 15:35:09 作者：张小鸣
这篇文章主要为大家详细介绍了使用CountDownLatch等待多线程全部执行完成，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
前言
CountDownLatch 允许一个或多个线程等待其他线程完成操作。
应用场景
假如有一个列表的大量数据等待处理，最后全部处理完毕后返回处理结果。普通做法就是从头遍历，一个个顺序执行，这样单线程处理效率不高，我们希望使用多线程的方式处理，同时在主线程等待所有子线程处理完成。
CountDownLatch的构造函数接收一个int类型的参数作为计数器，如果你想等待N个点完成，这里就传入N。
当我们调用一次CountDownLatch的countDown方法时，N就会减1，CountDownLatch的await会阻塞当前线程，直到N变成零。由于countDown方法可以用在任何地方，所以这里说的N个点，可以是N个线程，也可以是1个线程里的N个执行步骤。用在多个线程时，你只需要把这个CountDownLatch的引用传递到线程里。
示例代码
public static void main(String args[]){
//初始化计数
AtomicInteger count = new AtomicInteger(0);
//创建10个线程
ExecutorService executorService = Executors.newFixedThreadPool(10);
//设置CountDownLatch为10
CountDownLatch countDownLatch = new CountDownLatch(10);
for(int i=0;i<10;i++){
executorService.execute(() -> {
//每个线程累加10000次
for(int j=0;j<10000;j++){
count.addAndGet(1);
}
//线程最后执行countDown
countDownLatch.countDown();
});
}
try{
//调用await方法等待
countDownLatch.await();
}catch(Exception e){
e.printStackTrace();
}
System.out.println(count.toString());
}
最后的执行结果就是10*10000=100000，可见所有线程都处理完了。
扩展
CountDownLatch的await方法还支持超时时间的设置，当等待超时时间子线程还没执行完将不再等待继续执行主线程。
public boolean await(long timeout, TimeUnit unit)
熟练使用多线程处理，可以再处理大量重复性工作时发挥多线程处理的效率优势。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。
相关文章
这篇文章主要介绍了Java中的有限状态机(设计模式——状态模式),具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2023-08-08
将Apache Samza作业迁移到Apache Flink作业是一个复杂的任务,因为这两个流处理框架有不同的API和架构,本文我们就来看看如何使用Java实现samza转换成flink吧2024-11-11
这篇文章主要给大家介绍了关于java新人基础入门之递归调用的相关资料，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2021-02-02
java Spring Boot 配置redis pom文件操作
这篇文章主要介绍了java Spring Boot 配置redis pom文件操作，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2020-07-07
这篇文章主要介绍了Java动态代理和AOP应用,结合实例形式分析了java动态代理在AOP面向切面编程中的相关操作技巧与使用注意事项,需要的朋友可以参考下2019-07-07
大家好，本篇文章主要讲的是Java给PDF加水印并合并多个文件，感兴趣的同学赶快来看一看吧，对你有帮助的话记得收藏一下2022-02-02
这篇文章主要介绍了springboot整合腾讯云短信开箱即用,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2021-03-03
springboot项目中jackson-序列化-处理 NULL教程
这篇文章主要介绍了springboot项目中jackson-序列化-处理 NULL教程，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2020-10-10
所谓监听者模式，我理解的是构建一个容器存放所有被监听的线程或对象，监听每个线程或对象发生的变化，若某个线程或对象触发指定规则，那么则对所有被监听的线程或对象根据业务需要做处理2021-10-10
商品超卖是销售数量超过实际库存的情况,常因库存管理不当引发,传统库存管理在高并发环境下易出错,可通过线程加锁或使用Redis同步库存状态解决,本文就来详细的介绍一下,感兴趣的可以了解一下2024-09-09
最新评论