(三)线程同步ReentrantLock,condition(await,signal)
一.synchronized和ReentrantLock
故事
1. 我们前面(二)java 的线程同步(synchronized ,wait,notify)讲了synchronized的同步方法,java 就是这么神奇,这里又有一个同步的方法!当然,长江后浪推前浪,后者肯定比前者是由优越之处的。
先看看 synchronized 的一些限制:
1.1 :无法中断正在等候获取一个锁的线程
1.2 :无法通过投票得到一个锁
1.3 :释放锁的操作只能与获得锁所在的代码块中进行,无法在别的代码块中释放锁 。
ReentrantLock
类实现了 Lock
,它拥有与 synchronized
相同的并发性和内存语义,但是添加了类似锁投票、定时锁等候和可中断锁等候的一些特性。此外,它还提供了在激烈争用情况下更佳的性能。
定时锁等候:设置定时等候之后,在这个等候时间内如果没有获得这个锁,这个线程就会自己中断。
可中断锁等候:就是线程等候可以自己中断也可以别人中断。
锁投票:这个不太懂,有懂的大牛给提示一下,我到时引用到博文里面来(会注明作者的)。
二.ReentrantLock
的简单用法:
1.lock() 和unlock():ReentrantLock手动获取和释放锁,一般放在try catch 块中。如下所示
class X { private final ReentrantLock lock = new ReentrantLock(); // ... public void m() { lock.lock(); // block until condition holds try { // ... 同步的代码 } finally { lock.unlock() } } }
2.既然有锁,那多个线程下面的阻塞注明做到呢?这就需要用到Condiction类了,这个类的作用就相当于给ReentrantLock加类似synchronized的wait,notify方法,不过它更强大!它的await可以有条件的等待,比如定时等待等用法,为方便比较,我结合前面synchronized的例子改一下,例子如下所示:
package com.hxw.Threads; import java.util.concurrent.locks.Condition; import java.util.concurrent.locks.ReentrantLock; public class ProducerConsumeGameLock { /** * @param args */ public static void main(String[] args) { Bucket bucket = new Bucket(); // 构造篮子 new Thread(new Producer(bucket),"Producer线程").start(); new Thread(new Consumer(bucket),"Consumer线程").start(); } } final class Consumer implements Runnable { private Bucket bucket; public Consumer(Bucket bucket) { this.bucket = bucket; } @Override public void run() { for (int i = 0; i < 10; i++) { bucket.get(); } } } final class Producer implements Runnable { private Bucket bucket; public Producer(Bucket bucket) { this.bucket = bucket; } @Override public void run() { for (int i = 0; i < 10; i++) { // 来回十次交易 bucket.put((int) (Math.random() * 1000)); } } } class Bucket { private int packOdBalls; private boolean available = false; private final ReentrantLock lock = new ReentrantLock(); private Condition noBull = lock.newCondition(); private Condition fullBull = lock.newCondition(); public int get() { // 消费者从篮子里面取出球 lock.lock(); try { while (available == false) { // 如果没有就等着,但是为什么不是if呢?后面会做解析 System.out.println("消费者:暂时没有球可以消费我就等着..."); noBull.await(); // wait(); } System.out.println("消费者获得了" + packOdBalls + "个球"); available = false; System.out.println("持有消费线程数: "+lock.getHoldCount()); fullBull.signal(); // notify(); } catch (InterruptedException e) { e.printStackTrace(); } finally { lock.unlock(); } // 有的话就取出来 return packOdBalls; } public synchronized void put(int packOdBalls) { // 生产者将生产球并放入到篮子里面 lock.lock(); try { while (available) { System.out.println("生产者:既然篮子里面已经有球了我就消费完了再生产吧!"); fullBull.await(); // wait(); } this.packOdBalls = packOdBalls; available = true; System.out.println("生产者放进去了" + packOdBalls + "个球"); noBull.signal(); // notify(); } catch (InterruptedException e) { e.printStackTrace(); } finally { lock.unlock(); } } }
【运行结果与前面一样,需要看的可以戳文章头的链接】
三.ReentrantLock的方法…
1. public boolean tryLock():
仅在调用时锁未被另一个线程保持的情况下,才获取该锁。 这个方法会完全忽略公平策略,理解trylock的意思就知道了,就是“努力试着去锁”,所以一旦这个锁没有线程持有,他就抢占了!
2. public boolean tryLock(long timeout,TimeUnit unit):
如果锁在给定等待时间内没有被另一个线程保持,且当前线程未被中断,则获取该锁。说的详细点如果超出了指定的等待时间,则返回值为 false
。如果该锁没有被另一个线程保持,并且立即返回 true 值,则将锁的保持计数设置为 1。如果为了使用公平的排序策略,已经设置此锁,并且其他线程都在等待该锁,则不会 获取一个可用的锁。这与 tryLock() 方法相反。如果想使用一个允许闯入公平锁的定时 tryLock,那么可以将定时形式和不定时形式组合在一起:
if (lock.tryLock() || lock.tryLock(timeout, unit) ) { ... }
注意:有的人可能不理解这两个参数,其实就是前面是数词,后面是量词(SECOND,HOUR等等)
3. public int getHoldCount()查询当前线程保持此锁的次数。
4. public boolean isLocked()查询此锁是否由任意线程保持。
等等还有很多方法,这些查询方法都只能叫监控方法,因为线程无时无刻不在变化,可能返回这个值的下一纳秒,这个值就变了
5.还有一个构造方法:
public ReentrantLock(boolean fair)
创建一个具有给定公平策略的 ReentrantLock。
四.Condition方法一览…
1.await():
让当前线程一直处于等待状态,直到唤醒或中断。需要注意的是,这里说的是当前线程,这个“当前”指的是这个await所属Condition对象的线程创建者,这一点从上面的源码也可以看出(我们每个线程都new了一个Condition)。
对于唤醒,这里有个虚假唤醒,虚假唤醒也会引起当前线程唤醒,我们后面来讨论
2. boolean await(long time,TimeUnit unit):
让当前线程在指定时间内一直处于等待状态,直到被唤醒或中断。
3. void signal():唤醒一个等待线程。这个与notify功能类似
4. void signalAll():唤醒所有等待线程。这个与notifyAll功能类似
五.虚假唤醒
虚假唤醒简而言之就是一个signal()可能唤醒了多个线程,前面代码第60行左右提到过。当然这个概率是很低的,你会发现,你把while改成if也是可以运行的。但是我们也要避免这种情况,所以我们就改成了while,while()不仅仅在等待条件变量前检查条件变量,实际上在等待条件变量后也检查条件变量。
这样对condition进行多做一次判断,即可避免“虚假唤醒”.
相关推荐
内容概要:本文详细介绍了基于MATLAB GUI界面和卷积神经网络(CNN)的模糊车牌识别系统。该系统旨在解决现实中车牌因模糊不清导致识别困难的问题。文中阐述了整个流程的关键步骤,包括图像的模糊还原、灰度化、阈值化、边缘检测、孔洞填充、形态学操作、滤波操作、车牌定位、字符分割以及最终的字符识别。通过使用维纳滤波或最小二乘法约束滤波进行模糊还原,再利用CNN的强大特征提取能力完成字符分类。此外,还特别强调了MATLAB GUI界面的设计,使得用户能直观便捷地操作整个系统。 适合人群:对图像处理和深度学习感兴趣的科研人员、高校学生及从事相关领域的工程师。 使用场景及目标:适用于交通管理、智能停车场等领域,用于提升车牌识别的准确性和效率,特别是在面对模糊车牌时的表现。 其他说明:文中提供了部分关键代码片段作为参考,并对实验结果进行了详细的分析,展示了系统在不同环境下的表现情况及其潜在的应用前景。
嵌入式八股文面试题库资料知识宝典-计算机专业试题.zip
嵌入式八股文面试题库资料知识宝典-C and C++ normal interview_3.zip
内容概要:本文深入探讨了一款额定功率为4kW的开关磁阻电机,详细介绍了其性能参数如额定功率、转速、效率、输出转矩和脉动率等。同时,文章还展示了利用RMxprt、Maxwell 2D和3D模型对该电机进行仿真的方法和技术,通过外电路分析进一步研究其电气性能和动态响应特性。最后,文章提供了基于RMxprt模型的MATLAB仿真代码示例,帮助读者理解电机的工作原理及其性能特点。 适合人群:从事电机设计、工业自动化领域的工程师和技术人员,尤其是对开关磁阻电机感兴趣的科研工作者。 使用场景及目标:适用于希望深入了解开关磁阻电机特性和建模技术的研究人员,在新产品开发或现有产品改进时作为参考资料。 其他说明:文中提供的代码示例仅用于演示目的,实际操作时需根据所用软件的具体情况进行适当修改。
少儿编程scratch项目源代码文件案例素材-剑客冲刺.zip
少儿编程scratch项目源代码文件案例素材-几何冲刺 转瞬即逝.zip
内容概要:本文详细介绍了基于PID控制器的四象限直流电机速度驱动控制系统仿真模型及其永磁直流电机(PMDC)转速控制模型。首先阐述了PID控制器的工作原理,即通过对系统误差的比例、积分和微分运算来调整电机的驱动信号,从而实现转速的精确控制。接着讨论了如何利用PID控制器使有刷PMDC电机在四个象限中精确跟踪参考速度,并展示了仿真模型在应对快速负载扰动时的有效性和稳定性。最后,提供了Simulink仿真模型和详细的Word模型说明文档,帮助读者理解和调整PID控制器参数,以达到最佳控制效果。 适合人群:从事电力电子与电机控制领域的研究人员和技术人员,尤其是对四象限直流电机速度驱动控制系统感兴趣的读者。 使用场景及目标:适用于需要深入了解和掌握四象限直流电机速度驱动控制系统设计与实现的研究人员和技术人员。目标是在实际项目中能够运用PID控制器实现电机转速的精确控制,并提高系统的稳定性和抗干扰能力。 其他说明:文中引用了多篇相关领域的权威文献,确保了理论依据的可靠性和实用性。此外,提供的Simulink模型和Word文档有助于读者更好地理解和实践所介绍的内容。
嵌入式八股文面试题库资料知识宝典-2013年海康威视校园招聘嵌入式开发笔试题.zip
少儿编程scratch项目源代码文件案例素材-驾驶通关.zip
小区开放对周边道路通行能力影响的研究.pdf
内容概要:本文探讨了冷链物流车辆路径优化问题,特别是如何通过NSGA-2遗传算法和软硬时间窗策略来实现高效、环保和高客户满意度的路径规划。文中介绍了冷链物流的特点及其重要性,提出了软时间窗概念,允许一定的配送时间弹性,同时考虑碳排放成本,以达到绿色物流的目的。此外,还讨论了如何将客户满意度作为路径优化的重要评价标准之一。最后,通过一段简化的Python代码展示了遗传算法的应用。 适合人群:从事物流管理、冷链物流运营的专业人士,以及对遗传算法和路径优化感兴趣的科研人员和技术开发者。 使用场景及目标:适用于冷链物流企业,旨在优化配送路线,降低运营成本,减少碳排放,提升客户满意度。目标是帮助企业实现绿色、高效的物流配送系统。 其他说明:文中提供的代码仅为示意,实际应用需根据具体情况调整参数设置和模型构建。
少儿编程scratch项目源代码文件案例素材-恐怖矿井.zip
内容概要:本文详细介绍了基于STM32F030的无刷电机控制方案,重点在于高压FOC(磁场定向控制)技术和滑膜无感FOC的应用。该方案实现了过载、过欠压、堵转等多种保护机制,并提供了完整的源码、原理图和PCB设计。文中展示了关键代码片段,如滑膜观测器和电流环处理,以及保护机制的具体实现方法。此外,还提到了方案的移植要点和实际测试效果,确保系统的稳定性和高效性。 适合人群:嵌入式系统开发者、电机控制系统工程师、硬件工程师。 使用场景及目标:适用于需要高性能无刷电机控制的应用场景,如工业自动化设备、无人机、电动工具等。目标是提供一种成熟的、经过验证的无刷电机控制方案,帮助开发者快速实现并优化电机控制性能。 其他说明:提供的资料包括详细的原理图、PCB设计文件、源码及测试视频,方便开发者进行学习和应用。
基于有限体积法Godunov格式的管道泄漏检测模型研究.pdf
嵌入式八股文面试题库资料知识宝典-CC++笔试题-深圳有为(2019.2.28)1.zip
少儿编程scratch项目源代码文件案例素材-几何冲刺 V1.5.zip
Android系统开发_Linux内核配置_USB-HID设备模拟_通过root权限将Android设备转换为全功能USB键盘的项目实现_该项目需要内核支持configFS文件系统
C# WPF - LiveCharts Project
少儿编程scratch项目源代码文件案例素材-恐怖叉子 动画.zip
嵌入式八股文面试题库资料知识宝典-嵌⼊式⼯程师⾯试⾼频问题.zip