Java多线程CountDownLatch的实现

 更新时间:2022年02月18日 08:35:57   作者:胡安民  
本文主要介绍了Java多线程CountDownLatch的实现,文中通过示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下

介绍

CountDownLatch是一个同步辅助类,它允许一个或多个线程一直等待直到其他线程执行完毕才开始执行。

用给定的计数初始化CountDownLatch,其含义是要被等待执行完的线程个数。

每次调用CountDown(),计数减1

主程序执行到await()函数会阻塞等待线程的执行,直到计数为0

场景

1:多线程读取批量文件, 并且读取完成之后汇总处理

2:多线程读取Excel多个sheet,读取完成之后获取汇总获取的结果

3:多个人一起一起来吃饭,主人等待客人到来,客人一个个从不同地方来到饭店,主人需要等到所有人都到来之后,才能开饭

4:汽车站,所有乘客都从不同的地方赶到汽车站,必须等到所有乘客都到了,汽车才会出发,(如果设置了超时等待,那么当某个时间点到了,汽车也出发)

5: 百米赛跑,4名运动员选手到达场地等待裁判口令,裁判一声口令,选手听到后同时起跑,当所有选手到达终点,裁判进行汇总排名

6: 4名选手进行大众投票,投票现场有500个票, 投票时间是30分钟,500个票投完结束投票,或者投票时间到了也结束投票

作用:可以用来确保某些活动直到其他活动都完成后才继续执行。

CountDownLatch非常适合于对任务进行拆分,使其并行执行,比如某个任务执行2s,其对数据的请求可以分为五个部分,那么就可以将这个任务拆分为5个子任务,分别交由五个线程执行,执行完成之后再由主线程进行汇总,此时,总的执行时间将决定于执行最慢的任务,平均来看,还是大大减少了总的执行时间。

注意事项:

  • 使用CountDownLatch必须确保计数器数量与子线程数量一致,且countDown必须要执行,否则出现计数器不为0,导致主线程一致等待的情况
  • 在执行任务的线程中,使用了try...finally结构,该结构可以保证创建的线程发生异常时CountDownLatch.countDown()方法也会执行,也就保证了主线程不会一直处于等待状态。

案例(模拟乘客登机的场景)

    public static void main(String[] args) {
        CountDownLatchUtils.initialize("da1", 5);
        List<String> list=new CopyOnWriteArrayList<>();

        ExecutorUtils.create(()->{
            System.out.println("张三正在马鞍山,准备赶到南京坐飞机,需要1小时的车程到机场");
            SleepTools.second(4);
            list.add("张三");
            CountDownLatchUtils.countDown("da1");
        });
        ExecutorUtils.create(()->{
            System.out.println("李四正在徐州,准备赶到南京坐飞机,需要5小时的车程到机场");
            SleepTools.second(15);
            list.add("李四");
            CountDownLatchUtils.countDown("da1");
        });

        ExecutorUtils.create(()->{
            System.out.println("王五正在芜湖,准备赶到南京坐飞机,需要2小时的车程到机场");
            SleepTools.second(9);
            list.add("王五");
            CountDownLatchUtils.countDown("da1");
        });

        ExecutorUtils.create(()->{
            //飞机起飞
            CountDownLatchUtils.await("da1",10);  //这里先模拟10秒 360秒=1小时
            System.out.println("南京禄口机场_机长启动飞机起飞");
            //当前航班已到乘客
            System.out.println("当前航班已到乘客"+list);
        });
    }

以上代码都是我封装后的,主要是看逻辑就行了

张三正在马鞍山,准备赶到南京坐飞机,需要1小时的车程到机场
李四正在徐州,准备赶到南京坐飞机,需要5小时的车程到机场
王五正在芜湖,准备赶到南京坐飞机,需要2小时的车程到机场
南京禄口机场_机长启动飞机起飞
当前航班已到乘客[张三, 王五]

到此这篇关于Java多线程CountDownLatch的实现的文章就介绍到这了,更多相关Java多线程CountDownLatch内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • springboot如何获取yml里面的属性值

    springboot如何获取yml里面的属性值

    这篇文章主要介绍了springboot如何获取yml里面的属性值,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2022-02-02
  • Java启用Azure Linux虚拟机诊断设置

    Java启用Azure Linux虚拟机诊断设置

    这篇文章主要介绍了Java启用Azure Linux虚拟机诊断设置,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-05-05
  • lombok注解@Data使用在继承类上时出现警告的问题及解决

    lombok注解@Data使用在继承类上时出现警告的问题及解决

    Lombok的@Data注解简化了实体类代码,但在子类中使用时会出现警告,指出equals和hashCode方法不会考虑父类属性,解决方法有两种:一是在父类上使用@EqualsAndHashCode(callSuper=true)注解;二是通过配置lombok.config文件,均能有效解决警告问题
    2024-10-10
  • Java基础之教你如何正确运用依赖注入

    Java基础之教你如何正确运用依赖注入

    最近发现很多使用Spring框架的Java代码存在依赖注入方式的误用,甚至是滥用.因此整理了这篇文章,欢迎大家一起探讨,需要的朋友可以参考下
    2021-05-05
  • Java中的Set集合简单汇总解析

    Java中的Set集合简单汇总解析

    这篇文章主要介绍了Java中的Set集合简单汇总解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2019-10-10
  • Java 如何将网络资源url转化为File文件

    Java 如何将网络资源url转化为File文件

    这篇文章主要介绍了Java 如何将网络资源url转化为File文件的操作,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-09-09
  • 在maven中引入本地jar包的步骤

    在maven中引入本地jar包的步骤

    这篇文章主要介绍了在maven中引入本地jar包的步骤,帮助大家更好的理解和学习使用Java,感兴趣的朋友可以了解下
    2021-04-04
  • java合并list方法代码实例

    java合并list方法代码实例

    这篇文章主要介绍了java合并list方法代码实例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-01-01
  • Spring Boot读取自定义配置文件

    Spring Boot读取自定义配置文件

    在Spring Boot项目中我们经常需要读取application.yml配置文件的自定义配置,今天就来罗列一下从yaml读取配置文件的一些常用手段和方法。
    2021-05-05
  • Java实现有限状态机的推荐方案分享

    Java实现有限状态机的推荐方案分享

    有限状态机又称有限状态自动机,简称状态机,是表示有限个状态以及在这些状态之间的转移和动作等行为的数学模型,这篇文章主要给大家介绍了关于Java实现有限状态机的推荐方案,需要的朋友可以参考下
    2021-11-11

最新评论