闭锁 java_Java并发编程之闭锁
1、什么是闭锁?
闭锁(latch)是一种Synchronizer(Synchronizer:是一个对象,它根据本身的状态调节线程的控制流。常见类型的Synchronizer包括信号量、关卡和闭锁)。
闭锁可以延迟线程的进度直到线程线程到达终止状态。一个闭锁工作起来就像是一道大门:直到闭锁达到终点状态之前,门一直是关闭的,没有线程能够通过,在终点状态到来的时候,所有线程都可以通过。
2、应用场景
闭锁可以用来确保特定活动直到其他的活动都完成后才开始发生,比如:
确保一个计算不会执行,直到它所需要的资源被初始化
确保一个服务不会开始,直到它依赖的其他服务都已经开始
等待,直到活动的所有部分都为继续处理做好充分准备
死锁检测,可以使用n个线程访问共享资源,在每次测试阶段的线程数目是不同的,并尝试产生死锁
3、闭锁的实现
CountDownLatch是一个同步辅助类,存在于java.util.concurrent包下,灵活的实现了闭锁,它允许一个或多个线程等待一个事件集的发生。
CountDownLatch是通过一个计数器来实现的,计数器的初始值为线程的数量。每当一个线程完成了自己的任务后,计数的值就会减1。当计数器值到达0时,它所表示所有的线程已经完成了任务,然后在闭锁上等待的线程就可以恢复执行任务。
4、CountDownLatch原理
CountDownLatch构造函数:
CountDownLatch(int count);
构造器中计数值(count)就是闭锁需要等待的线程数量,这个值只能被设置一次。
CountDownLatch类的方法:
void await():使当前线程在锁存器倒计数至零之前一直等待,除非线程被中断。
boolean await(long timeout, TimeUnit unit):使当前线程在锁存器倒计数至零之前一直等待,除非线程被中断或超出了指定的等待时间。
void countDown():递减锁存器的计数,如果计数到达零,则释放所有等待的线程。
long getCount():返回当前计数。
String toString():返回标识此锁存器及其状态的字符串。
与CountDownLatch第一次交互是主线程等待其它的线程,主线程必须在启动其它线程后立即调用await方法,这样主线程的操作就会在这个方法上阻塞,直到其他线程完成各自的任务。
其他的N个线程必须引用闭锁对象,因为他们需要通知CountDownLatch对象,他们已经完成了各自的任务,这种机制就是通过countDown()方法来完成的。每调用一次这个方法,在构造函数中初始化的count值就减1,所以当N个线程都调用了这个方法count的值等于0,然后主线程就能通过await方法,恢复自己的任务。
5、CountDownLatch使用案例
下面介绍API中推荐的一种典型的用法。
首先给出两个类,其中一组worker线程使用了两个倒计数锁存器。
第一个类是一个启动信号,在driver为继续执行worker做好准备之前,它会阻止所有的worker继续执行。
第二个类是一个完成信号,它允许driver在完成所有的worker之前一直等待。
classDriver
{//...
private final static int N=10;public static void main(String[] args) throwsInterruptedException
{
CountDownLatch startSignal= new CountDownLatch(1);
CountDownLatch doneSignal= newCountDownLatch(N);for (int i = 0; i < N; ++i) //create and start threads
new Thread(newWorker(startSignal, doneSignal)).start();
doSomethingElse();//don't let run yet
startSignal.countDown(); //let all threads proceed
doSomethingElse();
doneSignal.await();//wait for all to finish
}private static voiddoSomethingElse()
{//doSomethingElse;
}
}
class Worker implementsRunnable
{private finalCountDownLatch startSignal;private finalCountDownLatch doneSignal;
Worker(CountDownLatch startSignal, CountDownLatch doneSignal)
{this.startSignal =startSignal;this.doneSignal =doneSignal;
}public voidrun()
{try{
startSignal.await();
doWork();
doneSignal.countDown();
}catch(InterruptedException ex)
{
}//return;
}voiddoWork()
{//...
}
}
基于上面的模型,下面我实现了自己的应用场景:
public classCountDownLatchDemo
{final static SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");public static void main(String[] args) throwsInterruptedException
{
CountDownLatch startLatch= new CountDownLatch(1);//开始工作
CountDownLatch endLatch = new CountDownLatch(2);//两个工人的协作
Worker worker1= new Worker("zhang san", 5000,startLatch, endLatch);
Worker worker2= new Worker("li si", 8000, startLatch,endLatch);
worker1.start();// worker2.start();//startLatch.countDown();//工作开始
endLatch.await();//等待所有工人完成工作
System.out.println("all work done at " + sdf.format(newDate()));
}static class Worker extendsThread
{
String workerName;intworkTime;
CountDownLatch startLatch;
CountDownLatch endLatch;public Worker(String workerName, intworkTime, CountDownLatch startLatch,CountDownLatch endLatch)
{this.workerName =workerName;this.workTime =workTime;this.startLatch=startLatch;this.endLatch =endLatch;
}public voidrun()
{try{
startLatch.await();//等待开始工作时间
System.out.println("Worker " + workerName + " do work begin at "+ sdf.format(newDate()));
Thread.sleep(workTime);
}catch(InterruptedException e)
{//TODO 自动生成的 catch 块
e.printStackTrace();
}finally{
System.out.println("Worker " + workerName + " do work complete at " + sdf.format(newDate()));
endLatch.countDown();//工人完成工作,计数器减一
}
}
}
}
执行的结果为:
六、参考资料
2、Java并发编程实践
闭锁 java_Java并发编程之闭锁相关推荐
- 闭锁java_实例讲解Java并发编程之闭锁
这篇文章主要介绍了实例讲解Java并发编程之闭锁,闭锁相当于一扇门,在闭锁到达结束状态之前,这扇门一直是关闭着的,没有任何线程可以通过,当到达结束状态时,这扇门才会打开并容许所有线程通过,需要的朋友可 ...
- 如何防止线程死锁java_Java 并发编程:如何防止在线程阻塞与唤醒时死锁
Java并发编程:多线程如何实现阻塞与唤醒 说到suspend与resume组合有死锁倾向,一不小心将导致很多问题,甚至导致整个系统崩溃.接着看另外一种解决方案,我们可以使用以对象为目标的阻塞,即利用 ...
- 剑问天下java_Java并发编程精讲
第1章 开宗明义[不看错过一个亿] 1-1 课程综述--特点和内容介绍 (16:07) 第2章 跨越第一座山"线程八大核心"[适用于纵观全貌] 2-1 纵观全貌--线程八大核心 ( ...
- 【Java并发编程】闭锁
(转自:https://www.cnblogs.com/xujian2014/p/5359684.html#_label5 侵删) 1.什么是闭锁? 闭锁(latch)是一种Synchronizer( ...
- ad hoc java_Java并发编程--线程封闭(Ad-hoc封闭 栈封闭 ThreadLocal)
线程封闭 实现好的并发是一件困难的事情,所以很多时候我们都想躲避并发.避免并发最简单的方法就是线程封闭.什么是线程封闭呢? 就是把对象封装到一个线程里,只有这一个线程能看到此对象.那么这个对象就算不是 ...
- aqs clh java_Java并发编程:AQS对CLH锁的优化
自旋锁适用于锁占用时间短,即锁保护临界区很小的情景AQS的自旋锁详解>.它需要保证各缓存数据的一致性,这可能会导致性能问题.因为在多处理器机器上每个线程对应的处理器都对同一个变量进行读写,而每次 ...
- 合同在线修改 java_Java并发编程实战-第四章
序文: 如果你没有时间阅读这本,那你就来对地方了.小编会将每一章刨去废话,取其精华.分享给大家.如果觉得可以请不要忘了关注小编.我会定期跟新java 中的经典书籍. 正文: 第四章:对象的组合(更加适 ...
- 并发编程 07—— 任务取消
Java并发编程实践 目录 并发编程 01-- ThreadLocal 并发编程 02-- ConcurrentHashMap 并发编程 03-- 阻塞队列和生产者-消费者模式 并发编程 04-- 闭 ...
- Java 并发编程系列之闭锁(CountDownLatch)
在讲闭锁之前,我们先来思考一个问题:在多线程环境下,主线程打印一句话,如何保证这句话最后(其他线程全部执行完毕)打印? 博主目前可以想到的实现方式有两种.一种是通过 join() 方法实现,另一种就是 ...
最新文章
- .NET 页面间传值的几种方法
- VMWare中CentOS系统不能上网的解决
- IO的几种分类(详细)
- [css] 有用过Flex吗?简要说下你对它的了解
- 【转】Postman系列五:Postman中电商网站cookie、token检验与参数传递实战
- 【CodeForces - 460C】Present(二分+树状数组)
- 学生电脑哪个牌子好_电脑桌哪个牌子好?如何选购电脑桌?2020年值得选购的电脑桌品牌推荐...
- Intel 64/x86_64/IA-32/x86处理器 - 指令格式(9) - 64位指令格式(通用格式)
- D7控件\dw_cd_VirtualTreeview_v4.5.2\Demos\Advanced---TVirtualStringTree用法
- 全国计算机信息高新技术办公软件应用模块,全国计算机信息高新技术办公软件应用模块(Windows系列)教案.doc...
- 解析ip数据包java_ip包,ip数据包,数据包或者包的理解
- pktgen-dpdk 使用笔记
- Visual Studio 2010旗舰版正式版序列号
- Frontiers in Nutrition专刊征稿(IF 6.59, 王进/刘连亮/Zhongbin Deng
- 长芯微LCM1118 16 位模数转换器 P2P替代ADS1118
- 调用PC端、手机、平板摄像头拍照
- C语言获取norflash大小,NOR Flash 编程
- 如何解决不能绘制网络模型,报错protobuf
- 巨噬细胞膜包覆的负载二氧化锰MnO2和顺铂Pt的仿生纳米粒(齐岳)
- css首行缩进(微信开发采坑随便)
热门文章
- Android辅助功能(Accessibility)简介
- java编写篮球比赛计分,android 篮球比赛计分器
- [32期] 想学PHP来兄弟连是正确的选择 初识兄弟连三周
- Linux下/etc/mdev.conf学习
- 命令行错误提示--系统找不到指定的文件
- Gson解析异常com.google.gson.JsonSyntaxException: java.lang.IllegalStateException: Expected BEGIN解决方案
- 20均线和60均线的关系和看点
- 王兴:8年时间,我对商业的思考
- Facade (外观)模式
- 基尔霍夫电压定律解析