Java多线程——带你看AQS框架源码

stackvoid 发布于2019-08-19 11:04 / 2361人阅读

摘要：作用是存储获取锁失败的阻塞线程。独占模式下，锁是线程独占的，而共享模式下，锁是可以被多个线程占用的。等方法就是让线程阻塞加入队列唤醒线程等。该方法其实就是自旋尝试获取锁或阻塞线程子类实现决定。

AQS，全称AbstractQueuedSynchronizer，是Concurrent包锁的核心，没有AQS就没有Java的Concurrent包。它到底是个什么，我们来看看源码的第一段注解是怎么说明

看完第一段，总结下

AQS是一个同步的基础框架，基于一个先进先出的队列。

锁机制基于一个状态值，它是原子值。

AQS的子类负责定义与操作这个状态值，但必须通过AQS提供的原子操作

AQS剩余的方法就是围绕队列，与线程阻塞唤醒等功能

基于以上概念，我们看看源码到底是这么实现这些功能的

AQS的成员变量

state

private volatile int state;
该变量标记为volatile，说明该变量是对所有线程可见的。作用在于每个线程改变该值，都会马上让其他线程可见，在CAS（可见锁概念与锁优化）的时候是必不可少的。在AQS类中，不会直接操作这个值，而是交由它的子类去操作和定义他的作用。

Node、head、tail

AQS中有一个静态内部类Node，其实现是一个双向链表。head与tail则是这个链表的头尾指针。作用是存储获取锁失败的阻塞线程。同样的，这个链表是会被多个线程操作的，所以它里面的变量多是被标记为volatile，并且操作也要通过CAS等原子方法去执行。
Node还有一个模式的属性：独占模式和共享模式。独占模式下，锁是线程独占的，而共享模式下，锁是可以被多个线程占用的。

VarHandler

对于大多数需要操作的原子属性，都对应会有一个大写的值，它的类是VarHandler。例如state、head、tail都有对应的VarHandler，STATE、HEAD、TAIL。VarHandler是1.9的新特性，提供了类似于原子操作以及Unsafe操作的功能，里面的原子操作大多是native方法，比较难查看源码。

ConditionObject

条件队列，是AQS中一个非常关键内部类。这个名字起非常奇异，让人搞不懂，看它类注释也看不懂说了什么。看看AQS头部注解

这个类是为了让子类支持独占模式的。深入看其中的源码实现，其实就是Node在功能性上的封装，最终让子类实现让当前线程怎么独占一个Object锁。await()、dosign()等方法就是让线程阻塞、加入队列、唤醒线程等。AQS框架下基本各种独占的加锁，解锁等操作到最后都是基于这个类实现的。该类是提供给子类去使用的，具体实现等下次说ReentranLock再深入了解。有人可能觉得为什么实现这个内部类，又不用，而是给子类去用，那为什么不放到子类去呢？其实答案，很简单，抽象加模板模式。

p.s. 只有独占锁才能配合该类使用。

AQS的成员函数

AQS的公用的方法，主要是加锁与解锁方法。以下方法只提供了模板，部分实现还是在子类当中，直接调用会抛出异常。

acquire()

尝试获取锁，失败则进入队列。

先执行tryAcquire()（子类实现），成功则直接返回，如果是获取锁失败，则执行addWaiter()，通过CAS在双向链表的尾部添加一个新独占节点。

然后把节点丢到acquireQueued()中执行。该方法其实就是自旋尝试获取锁或阻塞线程（子类实现决定）。一开始，获取新节点的前驱节点，如果这个节点是head，则证明只有两个节点，此时再次执行tryAcquire()尝试获取锁，若获取成功，则不需要中断，成功结束。

如果还是获取失败，则执行shouldParkAfterFailedAcquire()，根据前驱节点状态（子类设值）判断是否继续自旋（当waitStatus为初始值，重复上一步，直到前面的节点一直在减少到前驱节点为head）或者阻塞线程（当waitStatus标记为SIGNAL）

最后如果acquireQueued()返回需要阻塞，则执行selfInterrupt()设置线程为中断

可以看回acquire()函数的写法，十分的艺术。利用条件判断的短路规则，实现在if()条件内嵌套判断执行语音。一般人(笔者本人)如果要实现这个功能，会这么写

所以下次遇到类似嵌套if条件判断的语句，可以学习下acquire()的这种短路写法。赞

GPU云服务器云服务器 java多线程 java线程池源码多线程调试 java java多线程分发

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/76934.html

Java多线程框架源码阅读之---ReentrantLock非公平锁

摘要：注意是一个假节点，阻塞的节点是作为后面的节点出现的。总之在非公平锁场景下尝试去获取锁，如果获取上了，则置一下状态，并设置自己为独占线程，并支持重入锁功能。方法用于创建一个节点值为当前线程并维护一个双向链表。阻塞了当前线程。部分段落来自于http://javadoop.com/post/Abst...，他的文章相当不错。 ReentrantLock基于Sync内部类来完成锁。Sync继...

zacklee 2019-08-15 12:31 评论0 收藏0
J.U.C|可重入锁ReentrantLock

摘要：二什么是重入锁可重入锁，顾名思义，支持重新进入的锁，其表示该锁能支持一个线程对资源的重复加锁。将由最近成功获得锁，并且还没有释放该锁的线程所拥有。可以使用和方法来检查此情况是否发生。一、写在前面前几篇我们具体的聊了AQS原理以及底层源码的实现，具体参见《J.U.C|一文搞懂AQS》《J.U.C|同步队列（CLH）》《J.U.C|AQS独占式源码分析》《J.U.C|AQS共享式源...

wangdai 2019-08-16 17:00 评论0 收藏0
Java多线程框架源码阅读之---AQS的ConditionObject

摘要：前置文章为，如果不了解的基本和实现机制，建议先看一下这个文章。类似于和，常用于实现生产者消费者。以下代码是一个用的做的一个生产者消费者例子。前置文章为https://segmentfault.com/a/11...，如果不了解AQS的基本lock和unlock实现机制，建议先看一下这个文章。 Condition类似于wait和notify,notifyAll，常用于实现生产者消费者。...

Tonny 2019-08-15 12:30 评论0 收藏0
Java多线程进阶（十）—— J.U.C之locks框架：基于AQS的读写锁(5)

摘要：关于，最后有两点规律需要注意当的等待队列队首结点是共享结点，说明当前写锁被占用，当写锁释放时，会以传播的方式唤醒头结点之后紧邻的各个共享结点。当的等待队列队首结点是独占结点，说明当前读锁被使用，当读锁释放归零后，会唤醒队首的独占结点。 showImg(https://segmentfault.com/img/remote/1460000016012293); 本文首发于一世流云的专栏：...

dunizb 2019-08-19 10:50 评论0 收藏0
Java多线程进阶（八）—— J.U.C之locks框架：AQS的Conditon等待(3)

摘要：关于接口的介绍，可以参见多线程进阶二锁框架接口。最终线程释放了锁，并进入阻塞状态。当线程被通知唤醒时，则是将条件队列中的结点转换成等待队列中的结点，之后的处理就和独占功能完全一样。 showImg(https://segmentfault.com/img/remote/1460000016012490); 本文首发于一世流云的专栏：https://segmentfault.com/bl...

ityouknow 2019-08-19 10:50 评论0 收藏0