Java中的CountDownLatch简单理解

 更新时间:2024年01月17日 09:57:14   作者:java-zh  
这篇文章主要介绍了Java中的CountDownLatch简单理解,CountDownLatch是一个同步工具类,用来携调多个线程之间的同步,它是是使用一个计数器进行实现的,计数器初始值为线程数量,需要的朋友可以参考下

一、什么是CountDownLatch

CountDownLatch是一个同步工具类,用来携调多个线程之间的同步,它是是使用一个计数器进行实现的,计数器初始值为线程数量。

当每一个线程完成自己任务后,计数器的值就会减1。

当计数器的值为0时,表示所有的线程都已经完成一些任务,然后再CountDownLatch上等待的线程就可以恢复执行下来的任务。

二、哪些场景使用CountDownLatch

使用场景

  1. 某个线程需要在其他n个线程执行完毕后再往下执行。将CountDownLatch的计算器初始化化为new CountDownLatch(n),每当一个线程任务执行完毕,就将计数器减一(countDownLatch.countDown()),当计数器变为0的时候,在CountDownLatch上的线程就会被唤醒 。比如,启动一个服务时,主线程要等待多个组件加载完毕,之后在继续执行。
  2. 多个线程并行执行同一个任务,提高响应速度。注意时并行,不是并发,强调的是多个线程在某一时刻同时开始执行。类似于赛跑,将多个线程放到起点,等待起跑,然后同时开跑。做法是初始化一个共享的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简单理解内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • 详细总结IDEA中打jar包的两种方式

    详细总结IDEA中打jar包的两种方式

    发现有很多小伙伴都不会用IDEA打jar包,今天给大家详细总结了两种IDEA打jar包的方式,对正在学习IDEA使用的小伙伴很有帮助,需要的朋友可以参考下
    2021-05-05
  • Java循环队列原理与用法详解

    Java循环队列原理与用法详解

    这篇文章主要介绍了Java循环队列原理与用法,结合实例形式详细分析了Java循环队列基本概念、原理、用法及操作注意事项,需要的朋友可以参考下
    2020-03-03
  • java并发无锁多线程单线程示例详解

    java并发无锁多线程单线程示例详解

    这篇文章主要为大家介绍了java并发无锁多线程单线程示例详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2023-07-07
  • Spring Boot集成Swagger2项目实战

    Spring Boot集成Swagger2项目实战

    在日常的工作中,我们往往需要给前端(WEB端、IOS、Android)或者第三方提供接口,这个时候我们就需要给他们提供一份详细的API说明文档。这篇文章我们就来分享一种API文档维护的方式,即通过Swagger来自动生成Restuful API文档
    2018-01-01
  • SpringBoot配置SLF4J日志全过程

    SpringBoot配置SLF4J日志全过程

    这篇文章主要介绍了SpringBoot配置SLF4J日志全过程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2024-05-05
  • java自定义序列化的具体使用

    java自定义序列化的具体使用

    本文主要介绍了java自定义序列化的具体使用,文中通过示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2021-11-11
  • 关于Assert.assertEquals报错的问题及解决

    关于Assert.assertEquals报错的问题及解决

    这篇文章主要介绍了关于Assert.assertEquals报错的问题及解决方案,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2022-05-05
  • SpringMvc+POI处理excel表数据导入

    SpringMvc+POI处理excel表数据导入

    这篇文章主要为大家详细介绍了SpringMvc+POI处理excel表数据导入,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2018-06-06
  • 解决JDK版本冲突显示问题(双版本冲突)

    解决JDK版本冲突显示问题(双版本冲突)

    这篇文章主要介绍了解决JDK版本冲突显示问题(双版本冲突),具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2023-11-11
  • 一文搞懂Java中的反射机制

    一文搞懂Java中的反射机制

    这篇文章主要介绍了Java中反射机制的相关资料,帮助大家更好的理解和学习,感兴趣的朋友可以了解下
    2020-08-08

最新评论