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简单理解内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!
相关文章
Javaweb-HttpServletResponse的sendRedirectch重定向方式
这篇文章主要介绍了Javaweb-HttpServletResponse的sendRedirectch重定向方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2023-09-09使用SpringBoot AOP 记录操作日志、异常日志的过程
这篇文章主要介绍了使用SpringBoot AOP 记录操作日志、异常日志的过程,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下2021-05-05mybatis解决<foreach>标签不能超过1000的问题
MyBatis是一个开源的持久层框架,它可以帮助开发者简化数据库操作的编写,而foreach是MyBatis中的一个重要标签,用于在SQL语句中进行循环操作,本文主要给大家介绍了mybatis解决<foreach>标签不能超过1000的问题,需要的朋友可以参考下2024-05-05
最新评论