JUC.Condition学习笔记[附详细源码解析]
目录
Condition的概念
大体实现流程
I.初始化状态
II.await()操作
III.signal()操作
3个主要方法
Condition的数据结构
线程何时阻塞和释放
await()方法
signal()和signalAll()方法
Condition示例:生产者和消费者
JUC提供了Lock可以方便的进行锁操作,但是有时候我们也需要对线程进行条件性的阻塞和唤醒,这时我们就需要condition条件变量,它就像是在线程上加了多个开关,可以方便的对持有锁的线程进行阻塞和唤醒。
Condition的概念
Condition实质上是被绑定到一个锁上。
大体实现流程
3个主要方法
Condition的数据结构
线程何时阻塞和释放
await方法
1
2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 |
public final void await() throws InterruptedException {
// 1.如果当前线程被中断,则抛出中断异常 if (Thread.interrupted()) throw new InterruptedException(); // 2.将节点加入到Condition队列中去,这里如果lastWaiter是cancel状态,那么会把它踢出Condition队列。 Node node = addConditionWaiter(); // 3.调用tryRelease,释放当前线程的锁 long savedState = fullyRelease(node); int interruptMode = 0; // 4.为什么会有在AQS的等待队列的判断? // 解答:signal操作会将Node从Condition队列中拿出并且放入到等待队列中去,在不在AQS等待队列就看signal是否执行了 // 如果不在AQS等待队列中,就park当前线程,如果在,就退出循环,这个时候如果被中断,那么就退出循环 while (!isOnSyncQueue(node)) { LockSupport.park(this); if ((interruptMode = checkInterruptWhileWaiting(node)) != 0) break; } // 5.这个时候线程已经被signal()或者signalAll()操作给唤醒了,退出了4中的while循环 // 自旋等待尝试再次获取锁,调用acquireQueued方法 if (acquireQueued(node, savedState) && interruptMode != THROW_IE) interruptMode = REINTERRUPT; if (node.nextWaiter != null) unlinkCancelledWaiters(); if (interruptMode != 0) reportInterruptAfterWait(interruptMode); } |
signal和signalAll方法
await*()清楚了,现在再来看signal/signalAll就容易多了。按照signal/signalAll的需求,就是要将Condition.await*()中FIFO队列中第一个Node唤醒(或者全部Node)唤醒。尽管所有Node可能都被唤醒,但是要知道的是仍然只有一个线程能够拿到锁,其它没有拿到锁的线程仍然需要自旋等待,就上上面提到的第4步(acquireQueued)。
1
2 3 4 5 6 7 |
public final void signal() {
if (!isHeldExclusively()) throw new IllegalMonitorStateException(); Node first = firstWaiter; if (first != null) doSignal(first); } |
这里先判断当前线程是否持有锁,如果没有持有,则抛出异常,然后判断整个condition队列是否为空,不为空则调用doSignal方法来唤醒线程,看看doSignal方法都干了一些什么:
1
2 3 4 5 6 7 8 |
private void doSignal(Node first) {
do { if ( (firstWaiter = first.nextWaiter) == null) lastWaiter = null; first.nextWaiter = null; } while (!transferForSignal(first) && (first = firstWaiter) != null); } |
1
2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 |
final boolean transferForSignal(Node node) {
/* * 设置node的waitStatus:Condition->0 */ if (!compareAndSetWaitStatus(node, Node.CONDITION, 0)) return false; /* |
1
2 3 4 5 6 7 8 9 |
private void doSignalAll(Node first) {
lastWaiter = firstWaiter = null; do { Node next = first.nextWaiter; first.nextWaiter = null; transferForSignal(first); first = next; } while (first != null); } |
这个方法就相当于把Condition队列中的所有Node全部取出插入到等待队列中去。
Condition应用示例:生产者和消费者
Condition
实例实质上被绑定到一个锁上。要为特定 Lock
实例获得 Condition
实例,请使用其 newCondition()
方法。在最后我们来看一个应用示例
1
2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 |
/**
* 生产者、消费者示例 */ public class ConditionTest { private int storage; private int putCounter; private int getCounter; private Lock lock = new ReentrantLock(); private Condition putCondition = lock.newCondition(); private Condition getCondition = lock.newCondition(); public void put() throws InterruptedException { public void get() throws InterruptedException { public class PutThread extends Thread { public class GetThread extends Thread { public static void main(String[] args) { |
转载于:https://www.cnblogs.com/cm4j/p/juc_condition.html
JUC.Condition学习笔记[附详细源码解析]相关推荐
- K8s基础知识学习笔记及部分源码剖析
K8s基础知识学习笔记及部分源码剖析 在学习b站黑马k8s视频资料的基础上,查阅了配套基础知识笔记和源码剖析,仅作个人学习和回顾使用. 参考资料: 概念 | Kubernetes 四层.七层负载均衡的 ...
- 通俗易懂玩QT:Qpaint绘制开关按钮(内附详细源码)
Qpaint 绘制开关按钮(内附详细源码) 一.实验效果与开发环境 效果图如下: 开发环境: 二.实验代码 switch.h #ifndef SWITCH_H #define SWITCH_H#inc ...
- 实战|Python轻松实现动态网页爬虫(附详细源码)
用浅显易懂的语言分享爬虫.数据分析及可视化等干货,希望人人都能学到新知识. 项目背景 事情是这样的,前几天我公众号写了篇爬虫入门的实战文章,叫做<实战|手把手教你用Python爬虫(附详细源码) ...
- beautifulsoup解析动态页面div未展开_实战|Python轻松实现动态网页爬虫(附详细源码)...
用浅显易懂的语言分享爬虫.数据分析及可视化等干货,希望人人都能学到新知识.项目背景事情是这样的,前几天我公众号写了篇爬虫入门的实战文章,叫做<实战|手把手教你用Python爬虫(附详细源码)&g ...
- 自动化测试如何保持登录状态_自动化测试po模式是什么?自动化测试po分层如何实现?-附详细源码...
一.什么是PO模式 全称:page object model 简称:POM/PO PO模式最核心的思想是分层,实现松耦合!实现脚本重复使用,实现脚本易维护性! 主要分三层: 1.基础层BasePage ...
- Python编程:实现词云生成(附详细源码)
Python编程:实现词云生成(附详细源码) 词云是一种数据可视化的方式,它可以用来展示某个主题下的主要关键词汇.在Python中,我们可以使用 wordcloud 库来实现词云的生成.本文将带您一步 ...
- weiler-atherton多边形裁剪算法_EAST算法超详细源码解析:数据预处理与标签生成...
作者简介 CW,广东深圳人,毕业于中山大学(SYSU)数据科学与计算机学院,毕业后就业于腾讯计算机系统有限公司技术工程与事业群(TEG)从事Devops工作,期间在AI LAB实习过,实操过道路交通元 ...
- EAST算法超详细源码解析:数据预处理与标签生成
作者简介 CW,广东深圳人,毕业于中山大学(SYSU)数据科学与计算机学院,毕业后就业于腾讯计算机系统有限公司技术工程与事业群(TEG)从事Devops工作,期间在AI LAB实习过,实操过道路交通元 ...
- 【Java学习002】Java-ArrayList源码解析
ArrayList源码解析 1.1底层数据结构 定义:实现List接口的可扩容数组实现. 数组特点: 查询快:数组开辟的是连续空间,所以可以依靠索引进行快速查询. 增删慢:每次删除元素,都需要更改数组 ...
最新文章
- java中用byte[]数组实现的队列和用Byte[]实现的队列实际占用空间对比
- 长短期记忆(LSTM)相关知识
- leetcode双指针合集
- 编程实现将rdd转换为dataframe:源文件内容如下(_第四篇|Spark Streaming编程指南(1)
- sim7600ce 拨号上网测试_树莓派系列教程:通过SIM7600 4G模块NDIS拨号
- content的定义
- 搜索推荐广告中的Position Bias:美团DPIN
- 优雅的封装ajax,含跨域
- AfterEffects 不支持 MKV 格式的解决办法
- js:聚焦和失焦事件示例
- 计算机用户域怎么删除,如何删除域内非活动计算机账号?
- 详解java的垃圾清理机制
- Excel的图表:组成元素、图表类型与用途、图表可视化大全
- Mac 下生成keystore以及获得数字签名
- 清默网络——CCIE考试经验与心得(1)
- 09-word不显示段落标记(去掉回车符号)取消拼写错误
- Microbit试题
- win7怎么设置计算机的性能,windows7旗舰版电脑如何为电脑设置高性能计划
- 如何下载离线地图金字塔瓦片数据
- Smart-Link配置