Java 并发专题 :闭锁 CountDownLatch 之一家人一起吃个饭
最近一直整并发这块东西,顺便写点Java并发的例子,给大家做个分享,也强化下自己记忆。
每天起早贪黑的上班,父母每天也要上班,话说今天定了个饭店,一家人一起吃个饭,通知大家下班去饭店集合。假设:3个人在不同的地方上班,必须等到3个人到场才能吃饭,用程序如何实现呢?
作为一名资深屌丝程序猿,开始写代码实现:
- package com.zhy.concurrency.latch;
- public class Test1
- {
- /**
- * 模拟爸爸去饭店
- */
- public static void fatherToRes()
- {
- System.out.println("爸爸步行去饭店需要3小时。");
- }
- /**
- * 模拟我去饭店
- */
- public static void motherToRes()
- {
- System.out.println("妈妈挤公交去饭店需要2小时。");
- }
- /**
- * 模拟妈妈去饭店
- */
- public static void meToRes()
- {
- System.out.println("我乘地铁去饭店需要1小时。");
- }
- /**
- * 模拟一家人到齐了
- */
- public static void togetherToEat()
- {
- System.out.println("一家人到齐了,开始吃饭");
- }
- public static void main(String[] args)
- {
- fatherToRes();
- motherToRes();
- meToRes();
- togetherToEat();
- }
- }
输出结果:
- 爸爸步行去饭店需要3小时。
- 妈妈挤公交去饭店需要2小时。
- 我乘地铁去饭店需要1小时。
- 一家人到齐了,开始吃饭
看似实现了,但是吃个饭,光汇合花了6个小时,第一个到的等了3个小时;话说回来,大家下班同时往饭店聚集,怎么也是个并行的过程,于是不用我说,大家肯定都行想到使用多线程,于是作为一名资深屌丝程序猿,开始改造我们的代码:
- public static void main(String[] args)
- {
- new Thread()
- {
- public void run()
- {
- fatherToRes();
- };
- }.start();
- new Thread()
- {
- public void run()
- {
- motherToRes();
- };
- }.start();
- new Thread()
- {
- public void run()
- {
- meToRes();
- };
- }.start();
- togetherToEat();
- }
直接启动了3个线程,但是运行结果貌似也不对:
- 一家人到齐了,开始吃饭
- 我乘地铁去饭店需要1小时。
- 妈妈挤公交去饭店需要2小时。
- 爸爸步行去饭店需要3小时。
一个都没到,就开始吃饭了,,,(为了更好的显示,我在每个方法中休息了一段时间,模拟到达饭店的过程)。还是不行,那就继续完善:
- private static volatile int i = 3;
- public static void main(String[] args)
- {
- new Thread()
- {
- public void run()
- {
- fatherToRes();
- i--;
- };
- }.start();
- new Thread()
- {
- public void run()
- {
- motherToRes();
- i--;
- };
- }.start();
- new Thread()
- {
- public void run()
- {
- meToRes();
- i--;
- };
- }.start();
- while (i != 0);
- togetherToEat();
- }
我们定义了一个volatile修饰的int类型变量,初始值为3,当为0时代表一家人齐了,于是我们在主线程使用了一个忙等,一直等待所有人到达,这次效果看起来不错哦:
- 我乘地铁去饭店需要1小时。
- 妈妈挤公交去饭店需要2小时。
- 爸爸步行去饭店需要3小时。
- 一家人到齐了,开始吃饭
但是,忙等这样的代码对于CPU的消耗太巨大了,我们需要更好的实现方式。顺便说一下volatile,为什么我们用volatile修饰 i 呢, 因为当多个线程操作同一个变量时,为了保证变量修改对于其他线程的可见性,必须使用同步,volatile对于可见性的实现是个不错的选择,但是我们代码中的 i -- 也有可能因为并发造成一定的问题,毕竟i--不是原子操作,正常最好使用同步块或者AtomicLong.decrementAndGet()实现--。
说了这么多,标题上的CountLatchDown竟然没出现,所以最终版,必须让这哥们出来亮相了:
- private static CountDownLatch latch = new CountDownLatch(3);
- public static void main(String[] args) throws InterruptedException
- {
- new Thread()
- {
- public void run()
- {
- fatherToRes();
- latch.countDown();
- };
- }.start();
- new Thread()
- {
- public void run()
- {
- motherToRes();
- latch.countDown();
- };
- }.start();
- new Thread()
- {
- public void run()
- {
- meToRes();
- latch.countDown();
- };
- }.start();
- latch.await();
- togetherToEat();
- }
输出结果:
- 我乘地铁去饭店需要1小时。
- 妈妈挤公交去饭店需要2小时。
- 爸爸步行去饭店需要3小时。
- 一家人到齐了,开始吃饭
避免使用忙等,我们使用了CountDowmLatch 实现了我们的需求。下面具体介绍一下这个哥们:
Latch闭锁的意思,是一种同步的工具类。类似于一扇门:在闭锁到达结束状态之前,这扇门一直是关闭着的,不允许任何线程通过,当到达结束状态时,这扇门会打开并允许所有的线程通过。且当门打开了,就永远保持打开状态。
作用:可以用来确保某些活动直到其他活动都完成后才继续执行。
使用场景:
1、例如我们上例中所有人都到达饭店然后吃饭;
2、某个操作需要的资源初始化完毕
3、某个服务依赖的线程全部开启等等...
CountDowmLatch是一种灵活的闭锁实现,包含一个计数器,该计算器初始化为一个正数,表示需要等待事件的数量。countDown方法递减计数器,表示有一个事件发生,而await方法等待计数器到达0,表示所有需要等待的事情都已经完成
Java 并发专题 :闭锁 CountDownLatch 之一家人一起吃个饭相关推荐
- JAVA并发专题《前引篇》
写在前面 最近想根据自己平时的工作笔记和学习笔记,整理出一些JAVA专题类的系列文章.平时自己的笔记比较散,趁着这个机会进行系统化的整合一下,同时看到网上能形成体系化的知识点比较少,所以也趁着这个机会 ...
- Java并发编程:CountDownLatch、CyclicBarrier和Semaphore
2019独角兽企业重金招聘Python工程师标准>>> Java并发编程:CountDownLatch.CyclicBarrier和Semaphore 在java 1.5中,提供了一 ...
- 【Java 并发编程】CountDownLatch 简介
文章目录 I CountDownLatch 概念 II CountDownLatch 使用流程 III CountDownLatch API 简介 I CountDownLatch 概念 1. 概念 ...
- Java 并发专题 :FutureTask 实现预加载数据 在线看电子书、浏览器浏览网页等
继续并发专题~ FutureTask 有点类似Runnable,都可以通过Thread来启动,不过FutureTask可以返回执行完毕的数据,并且FutureTask的get方法支持阻塞. 由于:Fu ...
- Java 并发专题 CyclicBarrier 打造一个安全的门禁系统
分享一下我老师大神的人工智能教程.零基础!通俗易懂!风趣幽默!还带黄段子!希望你也加入到我们人工智能的队伍中来!https://blog.csdn.net/jiangjunshow 继续并发专题~ 这 ...
- Java 并发专题 : Semaphore 实现 互斥 与 连接池
继续并发方面的知识.今天介绍Semaphore,同样在java.util.concurrent包下. 本来准备通过例子,从自己实现到最后使用并发工具实现,但是貌似效果并不是很好,有点太啰嗦的感觉,所有 ...
- Java并发编程之CountDownLatch(闭锁)使用详解
package com.zhangxueliang.day_20191108;import java.util.concurrent.CountDownLatch;/*** 计算多线程的运行时间* @ ...
- Java并发编程之CountDownLatch闭锁
CountDownLatch 典型应用场景:主线程启动多个子线程同时执行业务逻辑,所有子线程都执行完毕,再唤醒主线程继续执行. 例子: public class CountDownLatchTest ...
- Java 多线程之闭锁-CountDownLatch
实现并发的最直接方式是在操作系统级别使用进程.进程是运行在自己的地址空间内的自包容程序.多任务操作系统可以通过周期性地将CPU从一个进程切换到另一个进程,来实现同时运行多个进程的.操作系统将进程相互隔 ...
最新文章
- nfs服务启动失败:Failed to start NFS status monitor for NFSv2/3 locking..
- php数组第二位,PHP将二位数组按照第二维的某个元素的值进行排序
- struts-config message-resources配置问题总结
- .NET Framework 工具下载
- VS CODE离线安装C/C++扩展的方法
- 构建高可用linux和鸟哥,构建高可用Linux服务器
- php对产品添加属性,php – Woocommerce:使用现有属性为现有产品添加变体
- 2021-08-22监听器实现在线客户端统计
- Centos yum安装snmp
- 本地化OElove婚恋交友系统源码+基于PHP开发
- 内网渗透之 windows 基础
- 计算机怎么设置ie连接网络连接不上去,有网络连接,但浏览器不能上网怎么办?电脑高手教你怎么解决...
- 安卓手机格式化怎么弄_安卓手机怎么格式化
- Win10提示“无法使用内置管理员账户打开计算器”解决方案
- 技术经理成长复盘-要懂一些项目管理的知识
- c语言如何小写转换为大写字母,c语言怎么将小写转换为大写
- 基于计算机底层基础设计一个高性能的单机管理主机的心跳服务
- OpenCV 书稿:前言
- 小程序自定义底部导航 custom-tab-bar
- ProGuard常见问题及解决套路
热门文章
- 华为云免费体验 怎么使用_华为云Classroom免费向全国高校开放,云端学习更高效...
- 大专计算机学语数英理化生吗,学考11-13号报名啦!你知道语数英和政史地/物化生成绩有什么作用嘛?不懂你会后悔的!!...
- sam格式的结构和意义_BAM/SAM文件格式的一些小知识
- python ftp服务器限速_用 Python 快速实现 HTTP 和 FTP 服务器
- mysql节假日表_节假日常见的数据库磁盘空间处理小结
- 为什么用1 << 16表示数
- HALCON测量工具
- error: ‘::main‘ must return ‘int‘
- 苹果airpods android,苹果AirPodsPro搭配Android手机实测:支持功能不够完整,购买前要认真考虑...
- 鸿蒙投屏和普通投屏,华为智慧屏SE发布:预装鸿蒙 可一碰投屏