Jdk并发线程处理CountDownLatch、CyclicBarrier、Semaphore
文章目录
- 1. CountDownLatch
- 1.1 描述
- 1.2 业务场景
- 1.3 代码
- 2. CyclicBarrier
- 2.1 说明
- 2.2 应用
- 2.3 代码
- 3. Semaphore
- 3.1 说明
- 3.2 应用
- 3.3 代码
- 3.1.1 获取一个许可
- 3.1.2 获取多个许可
- 3.1.3 尝试获取许可
- 3.1.4 指定时间内尝试获取许可
- 4. 补充(引用其他网友)
Java并发包提供了三个类,处理并发线程:CountdownLatch、Semaphore、CyclicBarrier。
1. CountDownLatch
1.1 描述
- 中文含义"
门栓
",当指定数量的线程全部执行完毕后,主线程才继续向后执行
。 - countDownLatch是一个一次性计数器,初始化需设置一个计数器的值。
- 调用
await
方法可阻塞当前线程。 - 调用一次
countDown
方法,计数器减1,当计数器减到0后,await方法阻塞的线程,继续向下执行。
1.2 业务场景
某个业务场景,程序需要分成很多线程一起执行,当全部子任务执行完成后(每个任务执行完,执行一次countDown,让计数器减1),再继续执行主程序后续的操作。
如并行计算,处理的数据量很大,将任务拆分成多个子任务,等所有子任务都完成后,父任务再拿到所有自认为的运算结果进行汇总。
1.3 代码
public static void main(String[] args) throws InterruptedException {AtomicInteger result=new AtomicInteger(0);int count=5;CountDownLatch countDownLatch=new CountDownLatch(5);for(int i=0;i<count;i++){new Thread(() -> {try {//业务逻辑...result.addAndGet(10);System.out.println(Thread.currentThread());}catch (Exception e){e.printStackTrace();}finally {//保证计数器能顺利减1,否则父线程将一直阻塞countDownLatch.countDown();}}).start();}//阻塞,等待计数器减为0countDownLatch.await();System.out.println("执行结果:"+result);
}
执行结果:
Thread[Thread-0,5,main]
Thread[Thread-1,5,main]
Thread[Thread-2,5,main]
Thread[Thread-3,5,main]
Thread[Thread-4,5,main]
执行结果:50
2. CyclicBarrier
2.1 说明
- 中文含义"
栅栏
",多个线程互相等待,只要有一个线程没完成(没到屏障点),所有线程都等待
。 - 调用await方法的线程告诉CyclicBarrier自己已经到达同步点,然后当前线程被阻塞。直到parties个参与线程调用了await方法,则全部阻塞的线程一起执行阻塞后面的代码。
- 父线程不会阻塞。
核心方法:
- 等待:await()
2.2 应用
2.3 代码
public class CyclicBarrierTest {/*** 执行数量5,配置执行后回调线程*/public static CyclicBarrier cyclicBarrier=new CyclicBarrier(5,() -> {System.out.println("----------满足要求 call back thread----------");});public static void main(String[] args) throws Exception{for(int i=0;i<5;i++){new Thread(()->{try {System.out.println("进入线程:"+Thread.currentThread());Thread.sleep(Long.valueOf(new Random().nextInt(3000)));System.out.println("线程前置方法执行结束:"+Thread.currentThread());//await会导致当前线程阻塞,当调用次数达到设置的值时,所有阻塞的线程将全部执行cyclicBarrier.await();System.out.println("满足条件,离开线程:"+Thread.currentThread());}catch (Exception e){e.printStackTrace();}}).start();}//父线程并不会阻塞System.out.println("主线程结束");}
}
执行结果:
主线程结束
进入线程:Thread[Thread-3,5,main]
进入线程:Thread[Thread-0,5,main]
进入线程:Thread[Thread-2,5,main]
进入线程:Thread[Thread-1,5,main]
进入线程:Thread[Thread-4,5,main]
线程前置方法执行结束:Thread[Thread-1,5,main]
线程前置方法执行结束:Thread[Thread-4,5,main]
线程前置方法执行结束:Thread[Thread-0,5,main]
线程前置方法执行结束:Thread[Thread-3,5,main]
线程前置方法执行结束:Thread[Thread-2,5,main]
----------满足要求 call back thread----------
满足条件,离开线程:Thread[Thread-2,5,main]
满足条件,离开线程:Thread[Thread-1,5,main]
满足条件,离开线程:Thread[Thread-4,5,main]
满足条件,离开线程:Thread[Thread-0,5,main]
满足条件,离开线程:Thread[Thread-3,5,main]
3. Semaphore
3.1 说明
- 中文含义”
信号量
“,保证同一批并发线程,最多同时执行的线程数,防止同时执行的线程过多
。 - 限制
最多
可以有几个线程进来,超过最大线程数,新进来的线程可以选择等待
,或者离开,如执行中的线程有结束的,则等待中的线程会自动
加入到执行队列中,执行后续操作。 - 可一次获取多个许可
核心方法:
- 获取权限:acquire()
- 释放权限:release()
3.2 应用
特别适用于要求一个并发任务最多有几个线程
执行的情况。
3.3 代码
3.1.1 获取一个许可
public static void main(String[] args) {//最多允许2个线程执行Semaphore semaphore=new Semaphore(2);for(int i=0;i<3;i++){new Thread(()->{try {//获取许可semaphore.acquire();//执行业务操作...System.out.println(Thread.currentThread()+"----拿到许可"+LocalTime.now()); Thread.sleep(Long.valueOf(new Random().nextInt(3000)));//释放许可semaphore.release();System.out.println(Thread.currentThread()+"----释放许可"+LocalTime.now()); }catch (Exception e){e.printStackTrace();}}).start();}System.out.println("执行结束");
}
执行结果:
执行结束
Thread[Thread-0,5,main]----拿到许可13:12:49.252
Thread[Thread-1,5,main]----拿到许可13:12:49.252
Thread[Thread-1,5,main]----释放许可13:12:49.906
Thread[Thread-2,5,main]----拿到许可13:12:49.906
Thread[Thread-2,5,main]----释放许可13:12:49.980
Thread[Thread-0,5,main]----释放许可13:12:51.535
3.1.2 获取多个许可
public static void main(String[] args) {//最多允许4个线程执行Semaphore semaphore=new Semaphore(4);for(int i=0;i<3;i++){new Thread(()->{try {//获取两个许可semaphore.acquire(2);//执行业务操作...System.out.println(Thread.currentThread()+"----拿到许可"+LocalTime.now()); Thread.sleep(Long.valueOf(new Random().nextInt(3000)));//释放两个许可semaphore.release(2);System.out.println(Thread.currentThread()+"----释放许可"+LocalTime.now()); }catch (Exception e){e.printStackTrace();}}).start();}System.out.println("执行结束");
}
执行结果:
执行结束
Thread[Thread-1,5,main]----拿到许可13:10:32.917
Thread[Thread-0,5,main]----拿到许可13:10:32.917
Thread[Thread-1,5,main]----释放许可13:10:33.208
Thread[Thread-2,5,main]----拿到许可13:10:33.208
Thread[Thread-2,5,main]----释放许可13:10:35.031
Thread[Thread-0,5,main]----释放许可13:10:35.491
3.1.3 尝试获取许可
public static void main(String[] args) {//最多允许2个线程执行Semaphore semaphore=new Semaphore(2);for(int i=0;i<5;i++){new Thread(()->{try {//获取许可if(semaphore.tryAcquire()){//执行业务操作...System.out.println(Thread.currentThread()+"----拿到许可"+LocalTime.now()); Thread.sleep(100);//释放许可semaphore.release();System.out.println(Thread.currentThread()+"----释放许可"+LocalTime.now()); }else{System.out.println(Thread.currentThread()+"----"+"未获取许可,放弃"+LocalTime.now());}}catch (Exception e){e.printStackTrace();}}).start();}System.out.println("执行结束");
}
执行结果:
执行结束
Thread[Thread-4,5,main]----未获取许可,放弃13:22:01.626
Thread[Thread-2,5,main]----未获取许可,放弃13:22:01.626
Thread[Thread-1,5,main]----拿到许可13:22:01.626
Thread[Thread-3,5,main]----未获取许可,放弃13:22:01.626
Thread[Thread-0,5,main]----拿到许可13:22:01.626
Thread[Thread-0,5,main]----释放许可13:22:01.727
Thread[Thread-1,5,main]----释放许可13:22:01.727
3.1.4 指定时间内尝试获取许可
public static void main(String[] args) {//最多允许2个线程执行Semaphore semaphore=new Semaphore(2);for(int i=0;i<5;i++){new Thread(()->{try {//获取许可if(semaphore.tryAcquire(1, TimeUnit.SECONDS)){//执行业务操作...System.out.println(Thread.currentThread()+"----"+LocalTime.now()+"----拿到许可"); Thread.sleep(Long.valueOf(new Random().nextInt(3000)));//释放许可semaphore.release();System.out.println(Thread.currentThread()+"----"+LocalTime.now()+"----释放许可"); }else{System.out.println(Thread.currentThread()+"----"+LocalTime.now()+"----1秒内未获取许可,放弃");}}catch (Exception e){e.printStackTrace();}}).start();}System.out.println("执行结束");
}
执行结果:
执行结束
Thread[Thread-3,5,main]----13:24:29.752----拿到许可
Thread[Thread-2,5,main]----13:24:29.752----拿到许可
Thread[Thread-2,5,main]----13:24:30.088----释放许可
Thread[Thread-0,5,main]----13:24:30.088----拿到许可
Thread[Thread-4,5,main]----13:24:30.732----1秒内未获取许可,放弃
Thread[Thread-1,5,main]----13:24:30.733----1秒内未获取许可,放弃
Thread[Thread-3,5,main]----13:24:31.929----释放许可
Thread[Thread-0,5,main]----13:24:32.340----释放许可
4. 补充(引用其他网友)
CountDownLatch和CyclicBarrier区别:
CountDownLatch和CyclicBarrier都有让多个线程等待同步然后再开始下一步动作的意思,但是CountDownLatch的下一步的动作实施者是主线程,具有不可重复性;
而CyclicBarrier的下一步动作实施者还是“其他线程”本身
Jdk并发线程处理CountDownLatch、CyclicBarrier、Semaphore相关推荐
- JUC介绍--常用辅助类(CountDownLatch CyclicBarrier Semaphore)
CountDownLatch减法计数器 每次有线程调用countDownLatch.countDown()数量就-1 数量减到0时,countDownLatch.await()会被唤醒,继续向下执行 ...
- (面经总结)一篇文章带你完整复习 Java 中并发关键字(CountDownLatch/CyclicBarrier/Semaphore/Volatile)
文章目录 一.倒计数器:CountDownLatch 二.循环栅栏:CyclicBarrier 三.信号量:Semaphore 四.volatile 关键字的作用 一.倒计数器:CountDownLa ...
- CountDownLatch CyclicBarrier Semaphore
CountDownLacth CountDownLacth(倒计数锁存器)到底有什么用呢?我们来看下面这个场景. 我们又有小片片要开始拍摄了,这个小片片需要5个演员来演,开演之前,导演需要这5个演员全 ...
- 高并发线程/锁/内存处理模型
文章目录 锁与线程 一.进程/线程的基本介绍 进程 线程 1 线程的调度与时间片 2 优先级 3 生命周期 进程与线程的区别 二.线程的使用 2.1 Thread类的介绍 2.2 创建线程的方法 Th ...
- Java并发编程:CountDownLatch、CyclicBarrier和 Semaphore
2019独角兽企业重金招聘Python工程师标准>>> 在java 1.5中,提供了一些非常有用的辅助类来帮助我们进行并发编程,比如CountDownLatch,CyclicBarr ...
- Java并发编程:CountDownLatch、CyclicBarrier和Semaphore
2019独角兽企业重金招聘Python工程师标准>>> Java并发编程:CountDownLatch.CyclicBarrier和Semaphore 在java 1.5中,提供了一 ...
- 并发学习之CountDownLatch、CyclicBarrier以及Semaphore
文章目录 一.java.util.concrrent.CountDownLatch 1.源码 2.基本使用:在循环中每个线程调用它的countDown()使count--,当count=0时,调用它的 ...
- springboot 压测 50并发 线程等待_线程池+CountDownLatch——高并发就是这么简单
今天和大家分享的是:在开发服务端API时候,如何合理的运用线程池+CountDownLatch来保证API的高并发访问. 首先,作为Java开发的同学来说,java.util.concurrent并发 ...
- 并发工具之CountDownLatch与CyclicBarrier
文章目录 倒计时器CountDownLatch 循环栅栏CyclicBarrier CountDownLatch与CyclicBarrier的比较 倒计时器CountDownLatch 在多线程协作完 ...
最新文章
- 手把手教你用Python玩转时序数据,从采样、预测到聚类
- 成功修改fastreport3.15,使其支持中日韩四(CJK)中编码PDF的导出
- 成功解决OSError: [Errno 28] No space left on device
- 计算机软件技能高考好考么,湖北技能高考:上不了本科,优先考虑这4所一档高职...
- 通过分区在Kafka中实现订单保证人
- mysql的配置实现远程访问_MySQL 远程连接配置的正确实现 | 学步园
- 飞鸽改变您的互联网生活
- c#日期转换周几_C#中获取任意日期为星期几三种方法分享
- python格式化输出作业_Python格式化输出
- java代码输出1到100的质数
- 在C++里while语句的一个妙用
- 青春互撩——详解基于Socket通信的聊天软件开发(附项目源码)
- 中国电子学会C++软件编程一级—六级历年真题模拟题题库260题及参考答案第六版 (星卯教育)TB
- 淘宝商品详情,1688商品详情滑块的解决方法和接口
- 命令式和声明式,哪个才是你的菜
- 学习java随堂练习-20220617
- 优雅!用了这两款插件,我成了整个公司代码写得最规范的码农
- 牢骚:各种奇奇怪怪的问题。。。
- 随身WiFi制作Linux服务器
- 用友U8不得不说的问题
热门文章
- 详谈RDMA(远程直接内存访问)技术原理和三种实现方式
- Linux RMAP
- C++ Web 编程 CGI公共网关接口(CGI):第一个 CGI 程序
- python到包快捷键_如何最简单、通俗地理解Python的包?
- python中typeerror_python – TypeError:ufunc subtract不能使用类型为dtype(‘
- Mysql的日期查询方法
- Mybatis解析(面试题)
- php get验证,PHP+Ajax简单get验证操作示例
- 宝塔无法安装php memcached,宝塔面板安装Memcached缓存加速wordpress
- 按键精灵bmp图片怎么导出_发光字怎么制作,招牌LED发光字工艺