Java并发工具CountDownLatch使用详解
本文目录
- 1、使用场景
- 2、使用介绍
- 3、使用案例
- 4、 Thread.join()和CountDownLatch的区别
1、使用场景
通过使用 CountDownLatch
可以使当前线程阻塞,等待其他线程完成给定任务。可以类比旅游团导游要等待所有的游客到齐后才能去下一个景点。
CountDownLatch
主要应用场景:一个线程等待多个线程完成给定任务后,然后执行后续的操作的场景。
2、使用介绍
CountDownLatch
的构造函数接收一个int类型的参数作为计数器,如果你想等待N个点完 成,这里就传入N。这里所说的N个 点,可以是N个线程,也可以是1个线程里的N个执行步骤。CountDownLatch
构造函数如下:
public CountDownLatch(int count) {if (count < 0) throw new IllegalArgumentException("count < 0");this.sync = new Sync(count);}
计数器参数count必须大于等于0,等于0的时候,调用await方法时不会 阻塞当前线程。
当我们调用CountDownLatch
的countDown()
方法时,N就会减1,CountDownLatch
的await()
方法 会阻塞当前线程,直到N变成零。
CountDownLatch
方法
await()
阻塞当前线程,直到计数器为零为止;await(long timeout, TimeUnit unit)
await()
的重载方法,可以指定阻塞时长;countDown()
计数器减1,如果计数达到零,释放所有等待的线程。getCount()
返回当前计数
3、使用案例
使用多线程下载网络上图片,现在完成后,提示用户下载完成。
public class DownLoadWorker implements Runnable{private String url;private CountDownLatch countDownLatch;public DownLoadWorker(String url, CountDownLatch countDownLatch) {this.url = url;this.countDownLatch = countDownLatch;}@Overridepublic void run() {//省略无数业务代码System.out.println("线程" + Thread.currentThread().getName() + "开始下载完成");countDownLatch.countDown();}
}public static void main(String[] args) throws InterruptedException {CountDownLatch countDownLatch=new CountDownLatch(5);//使用Stream 生成5个线程List<Thread> workers = Stream.generate(() -> new Thread(new DownLoadWorker("https://image.baidu.com/", countDownLatch))).limit(5).collect(toList());//运行线程workers.forEach(Thread::start);//等待线程完成countDownLatch.await();System.out.println("图片已下载完~~~");
}
4、 Thread.join()和CountDownLatch的区别
Thread.join()
是Thread类的一个方法,Thread.join()
的实现是依靠Object的wait()
和notifyAll()
来完成的,而CountDownLatch
是JUC包中的一个工具类。当我们使用
ExecutorService
,就不能使用join
,必须使用CountDownLatch
比如:ExecutorService service = Executors.newFixedThreadPool(5); final CountDownLatch latch = new CountDownLatch(5); for(int x = 0; x < 5; x++) {service.submit(new Runnable() {public void run() {// do somethinglatch.countDown();}}); } latch.await();
调用join方法需要等待thread执行完毕才能继续向下执行,而CountDownLatch只需要检查计数器的值为零就可以继续向下执行,相比之下,
CountDownLatch
更加灵活一些,可以实现一些更加复杂的业务场景。
Java并发工具CountDownLatch使用详解相关推荐
- Java并发工具类--CyclicBarrier详解
CyclicBarrier允许一组线程在到达某个栅栏点(common barrier point)互相等待,直到最后一个线程到达栅栏点,栅栏才会打开,处于阻塞状态的线程恢复继续执行. 举例 举个例子来 ...
- Java并发编程之CyclicBarrier详解
简介 栅栏类似于闭锁,它能阻塞一组线程直到某个事件的发生.栅栏与闭锁的关键区别在于,所有的线程必须同时到达栅栏位置,才能继续执行.闭锁用于等待事件,而栅栏用于等待其他线程. CyclicBarrier ...
- Java并发编程最佳实例详解系列
Java并发编程最佳实例详解系列: Java并发编程(一)线程定义.状态和属性 Java并发编程(一)线程定义.状态和属性 线程是指程序在执行过程中,能够执行程序代码的一个执行单元.在java语言中, ...
- 并发工具类使用详解及区别(CountDownLatch、CyclicBarrier、Semaphore、Exchanger)
本文转载自:码农历险记 CountDownLatch CountDownLatch介绍 CountDownLatch是一个同步工具类,它允许一个或多个线程一直等待,直到其他线程执行完后再执行.例如,应 ...
- Java并发编程之AQS详解
一.概述 谈到并发,不得不谈ReentrantLock:而谈到ReentrantLock,不得不谈AbstractQueuedSynchronizer(AQS)! 类如其名,抽象的队列式的同步器,AQ ...
- Java并发编程之ConcurrentLinkedQueue详解
简介 在并发编程中我们有时候需要使用线程安全的队列.如果我们要实现一个线程安全的队列有两种实现方式一种是使用阻塞算法,另一种是使用非阻塞算法.使用阻塞算法的队列可以用一个锁(入队和出队用同一把锁)或两 ...
- java并发编程Future类详解
作用和举例 future类的作用就是为了调用其他线程完成好后的结果,再返回到当前线程中,如上图举例: 小王自己是主线程,叫外卖等于使用future类,叫好外卖后小王就接着干自己的事去了,当外卖到了的时 ...
- 吃透Java并发:AQS结构详解及其CLH变种、CLH、MCS
目录 1.前言 2.AQS的构成 2.1 状态信息state 2.2 节点信息Node 2.3 阻塞/唤醒 2.4 当前持有锁线程 2.5 头结点与尾节点 3.CLH队列 3.1 CLH锁 3.2 M ...
- Java xml 工具 JDOM 使用详解.
一, 什么是JDOM工具 在编程中, 我们往往需要一些配置数据, 这些值我们一般不会hardcode在代码中的. 而是写在配置文件. 在Java世界中, 我们通常会把配置变量写在xml文件中. 而x ...
最新文章
- 作业 3 应用分支与循环结构解决问题 统计字符个数
- Pymetrics开源公平性感知机器学习算法Audit AI
- 【题解】Atcoder ARC#90 F-Number of Digits
- 深度学习之卷积神经网络 LeNet
- 本科毕业找不到工作,是怎样的体会
- Android学习小Demo(19)利用Loader来实时接收短信
- 用Java实现修改头像
- ProE/Creo免费插件 MCADEx Tools 5.0
- 凯恩帝数控系统面板介绍_KND凯恩帝数控系统说明书.doc
- RouterOS(ROS)软路由端口映射转发回流
- 禁止Tencent Upd
- 跳一跳小游戏刷分解读
- 并行执行linux命令,如何使用Parallel在Shell中并行执行命令
- 开利网络拜访普恺图酒业总部,品高端酒,探共赢合作方案
- 系统介绍python魔法方法
- 【Lintcode】1367. Police Distance
- mapbox pbf矢量瓦片读取(附pbf瓦片文件qt可视化工具源码)
- openwrt下的网络设置过程
- 游戏大全(持续更新中……)
- 最大公约数程序c语言,C语言求最大公约数(两种最简单的算法实现)
热门文章
- 特别行动队[斜率优化]
- Android音乐播放器的缓存机制设计
- 新房装修后如何去除甲醛?孕妇和宝宝多久可以入住新房。
- 解决app按home键运行到后台,再次运行程序避免再次开启app的MAIN页面
- 04-CSS选择器:伪类
- 使用机器学习算法预测航班价格
- MSSQL2005差异备份拿shell (MSSQL2005 Backup Get Shell)
- java毕业设计动漫网站Mybatis+系统+数据库+调试部署
- HttpServletRequest添加header
- vue el-table 显示/隐藏列异常-表格数据域高度变小