Java中的AQS同步队列问题详解
作者:beordie 发布时间:2021-08-16 19:50:23
AQS 同步队列
1、AQS 介绍
AQS
是 AbstractQueuedSynchronizer 的缩写,他是一个抽象同步类,为 JUC
包下的大多数同步工具提供了核心实现,例如 ReentrantLock 的底层就是使用同步队列。AQS 提供一套基础的机制来实现线程的同步、阻塞与唤醒、等待队列等功能,也就是想要深入学习线程工具类,这个同步队列就必须得掌握。
1.1、类图关系
下面是整个 AQS
的类结构实现(从源码中直接打印的图,平常学习源码也可以这样打印出来观察整个程序的运行情况,有助于理解),从图中我们不难发现 AQS
内部持有两个 Node 类型的 head 、tail 属性,我们在什么时候会接触到头尾节点的定义,大家都是有经验的开发人员,肯定都能想到是链表当中。
在属性列中我们可以看见一个 state:int
这样的一个状态字段,Lock 的重入特性就是根据此来实现的,可以表示当前线程的锁重入次数。整个类继承自 AbstractOwnableSynchronizer 类,自然拥有对于其父类中属性的一些控制权,而里面的 Thraed
的线程就是表示当前持有锁的线程,在整个锁过程中具有很重要的地位。
1.2、节点剖析
当然链表只是一种组织存储形式的一种数据结构,这里叫做 FIFO
双向队列,至于为什么是双向的呢,看一下 Node
的节点定义就能明白,一个节点中含有 prev 、next 节点来快速访问前驱和后继节点,不就是典型的双向形式呢。
相信大家在看到这个类字段的属性名定义之后就能才出来其的作用,但是这里还是介绍一下主要的几个字段含义,印证大家的猜想。
属性 | 作用 |
---|---|
thread | 表示当前节点封装的具体线程 |
SHARED | 表示当前线程是获取共享资源时被阻塞 |
EXCLUSIVE | 表示当前线程是获取独占资源时被挂起 |
prev | 当前节点的前驱节点 |
next | 当前节点的后继节点 |
waitStatus | 记录当前线程的等待状态,其状态取值就是下面的四个字段 |
CANCELLED | 取消线程 |
SIGNAL | 线程需要被唤醒 |
CONDITION | 线程在 condition 中等待 |
PROPAGATE | 释放共享资源时需要通知其余节点线程 |
2、AQS 实现原理
上面我们知道了 AQS
其实就是一个双向的队列,如下图的结构一样。在线程获取锁失败的情况下,会被封装成一个 Node 节点而插入到队列当中;当其他的线程释放锁之后又会从队列中唤醒一个节点去争抢锁。
2.1、队列初始化
通过源码我们可以发现,在 AQS
进行初始化的时候的并没有对 head 、tail 进行初始化,而这两个节点是控制整个队列的,也就是说一开始整个队列处于 null 状态。
protected AbstractQueuedSynchronizer() {}
当第一个线程争抢锁失败之后会封装成 Node 进入到同步队列当中,这个时候就会进行判断,如果当前队列为空就会进行初始化(未进行初始化),初始化完成之后就将当前线程节点接在队列的尾部。
private final void initializeSyncQueue() {
Node h;
if (HEAD.compareAndSet(this, (Void)null, h = new Node())) {
this.tail = h;
}
}
2.2、追加节点
追加节点的操作就是简单的链表尾部添加节点的过程了,这里就不做过多的赘述。这里来看看前面初始化时会添加一个额外的节点在队列中,其实这个节点就是代表当前已经获取了锁的线程,至于为什么这么设置,大家往后看就明白了。
3、AQS 唤醒动作
在进行线程唤醒的过程中,会优先唤醒当前持有锁线程的下一个节点线程。
head 指针指向下一个节点;
原来头结点的 next 指向 null;
当前头结点的 prev 指向 null;
当前头结点的 thread 指向 null。
这样就完成线程的唤醒操作了,但是这样来讲其实是不完美的,因为 AQS
只是一个抽象的统一工具,本身并没有对业务进行规范,还是要结合具体的实现类,例如 ReentrantLock 、CountDownLatch 、CyclicBarrier 这些的执行过程来进行分析。
来源:https://juejin.cn/post/7106029266021646372


猜你喜欢
- 本文实例为大家分享了Android实现图片点击 * 效果的具体代码,供大家参考,具体内容如下实现效果:需要注意的点:ValueAnimator
- 问题 @Cacheable注解不支持配置过期时间,所有需要通过配置CacheManneg来配置默认的过期时间和针对每个类或者是方法进行缓存
- 本文实例为大家分享了java实现猜数字小游戏的具体代码,供大家参考,具体内容如下介绍:电脑随机生成一个1-100的随机数,用户输入一个数;电
- 手机游戏实现Android隐藏虚拟按键,供大家参考,具体内容如下在华为等型号的手机会有虚拟按键,在进入游戏的时候,需要全屏隐藏这个按键,并在
- 前言尽管可以通过不同的方式组合IO流类,但我们可能也就只用到其中的几种组合。下面的例子可以作为典型的IO用法的基本参考。在这些示例中,异常处
- 一、导入前言:导入必须用post请求具体原因在2中叙述1、Excel导入总结一下目标,就是要将excel中的数据行、逐一提取,最后得到一个l
- 前言用户注册功能是每一个系统的入口门面功能,很多人可能会以为很简单,不就是一个简单的CRUD吗?其实不然,要把前后端功能都做出来,页面跳转也
- 首先贴一下搭配的环境:配置:Eclipse4.3.2jdk1.7_45Mysql 5.0+然后切入正题:1、login.jsp主要是使用OG
- 一. 假设需求场景在我们开发的过程中,经常出现两个对象存在一对多或多对一的关系。如何在程序在表明这两个对象的关系,以及如何利用这种关系优雅地
- 实现需求:1.用户未登录,跳转到登录页,登录完成后会跳到初始访问页。2.用户自定义处理(如需要激活),跳转到激活页面,激活完成后会跳到初始访
- < drawable name="white">#FFFFFF< /drawable><
- 话不多说,请看代码:System.Math.Abs(float value);System.Math.Abs(decimal value);
- 通过程序自动的读取其它网站网页显示的信息,类似于爬虫程序。比方说我们有一个系统,要提取BaiDu网站上歌曲搜索排名。分析系统在根据得到的数据
- 我先解释一下什么叫IO流:I:指的是InputStream,这是一个抽象类,最常用的子类是FileInputStreamO:值得是Outpu
- 本文实例讲述了Android EditText限制输入字数的方法。分享给大家供大家参考,具体如下://新浪微博字数限制private sta
- 一、RFC882文档简单说明RFC882文档规定了如何编写一封简单的邮件(纯文本邮件),一封简单的邮件包含邮件头和邮件体两个部分,邮件头和邮
- 在实际应用中,我们往往有需要比较两个自定义对象大小的地方。而这些自定义对象的比较,就不像简单的整型数据那么简单,它们往往包含有许多的属性,我
- 由于要做一个新项目,所以打算做一个简单的图片验证码。先说说思路吧:在服务端,从一个文件夹里面找出8张图片,再把8张图片合并成一张大图,在8个
- 前言convert 叫强制转换,可以是其他类型。最近在工作中遇到一个问题,需要将字符串形式的数值转换回数值,很正常的要求吧。却遇到了问题,下
- 1.springboot 2.0 默认连接池就是Hikari了,所以引用parents后不用专门加依赖2.贴我自己的配置(时间单位都是毫秒)