抽象同步队列AQS——AbstractQueuedSynchronizer锁详解
AQS——锁的底层支持
谈到并发，不得不谈ReentrantLock;而谈到ReentrantLock，不得不谈AbstractQueuedSynchronizer（AQS）！html
类如其名，抽象的队列式的同步器，AQS定义了一套多线程访问共享资源的同步器框架，许多同步类实现都依赖于它，如经常使用的ReentrantLock/Semaphore/CountDownLatch...java
并发包的底层就是使用AQS实现的，如下是AQS的类图结构node
框架
它维护了一个volatile int state（表明共享资源）和一个FIFO线程等待队列（多线程竞争资源被阻塞会进入此队列）。这里volatile保证线程可见性。编程
state的访问方式有三种：安全
getState（）多线程
setState（）并发
compareAndSetState（）框架
这三种都是原子操做，其中compareAndSetState的实现依赖于Unsafe的compareAndSwapInt（）方法。代码以下：函数
protected final boolean compareAndSetState(int expect, int update) {
// See below for intrinsics setup to support this
return unsafe.compareAndSwapInt(this, stateOffset, expect, update);
}
自定义资源共享方式
AQS定义了两种资源共享方式：Exclusive（独占，只有一个线程能执行，如ReentantLock）和Share（共享，多个线程可同时执行，如Semaphore/CountDownLatch）。oop
不一样的自定义同步器争用共享资源的方式也不一样，自定义同步器在实现时只须要实现共享资源state的获取与释放方式便可，至于具体线程等待队列的维护（如获取资源失败入队/唤醒出队等），AQS已经在顶层实现好了。自定义同步器实现时主要实现如下几种方法。
isHeldExclusively()：该线程是否正在独占资源。只有用到condition才须要去实现它。
tryAcquire(int)：独占方式。尝试获取资源，成功则返回true，失败则返回false。
tryRelease(int)：独占方式。尝试释放资源，成功则返回true，失败则返回false。
tryAcquireShared(int)：共享方式。尝试获取资源，负数表示失败;0表示成功，但没用剩余可用资源；正数表示成功，且有剩余资源。
tryReleaseShared(int)：共享方式。尝试释放资源，若是释放后容许唤醒后续等待节点返回true，不然返回false。
以ReentrantLock为例，state初始化为0，表示未锁定状态。A线程lock()时，会调用tryAcquire()独占该锁并将state+1。此后，其余线程再tryAcquire()时就会失败，直到A线程unlock()到state=0（即释放锁）为止，其它线程才有机会获取该锁。固然，释放锁以前，A线程本身是能够重复获取此锁的（state会累加），这就是可重入的概念。但要注意，获取多少次就要释放多么次，这样才能保证state是能回到零态的。
再以CountDownLatch以例，任务分为N个子线程去执行，state也初始化为N（注意N要与线程个数一致）。这N个子线程是并行执行的，每一个子线程执行完后countDown()一次，state会CAS减1。等到全部子线程都执行完后(即state=0)，会unpark()主调用线程，而后主调用线程就会从await()函数返回，继续后余动做。
通常来讲，自定义同步器要么是独占方法，要么是共享方式，他们也只需实现tryAcquire-tryRelease、tryAcquireShared-tryReleaseShared中的一种便可。但AQS也支持自定义同步器同时实现独占和共享两种方式，如ReentrantReadWriteLock。
源码实现
接下来咱们开始开始讲解AQS的源码实现。依照acquire-release、acquireShared-releaseShared的次序来。
1. acquire(int)
acquire是一种以独占方式获取资源，若是获取到资源，线程直接返回，不然进入等待队列，直到获取到资源为止，且整个过程忽略中断的影响。该方法是独占模式下线程获取共享资源的顶层入口。
获取到资源后，线程就能够去执行其临界区代码了。下面是acquire()的源码
public final void acquire(int arg) {
if (!tryAcquire(arg) &&
acquireQueued(addWaiter(Node.EXCLUSIVE), arg))
selfInterrupt();
}
经过注释咱们知道，acquire方法是一种互斥模式，且忽略中断。该方法至少执行一次tryAcquire(int)方法,若是tryAcquire(int)方法返回true，则acquire直接返回，不然当前线程须要进入队列进行排队。函数流程以下
一、tryAcquire()：尝试直接获取资源，若是成功则直接返回；
二、addWaiter()：将该线程加入等待队列的尾部，并标记为独占模式；
三、acquireQueued()：使线程在等待队列中获取资源，一直获取到资源后才返回。若是在整个等待过程当中被中断过，则返回true，不然返回false。
四、若是线程在等待过程当中被中断过，它是不响应的。只有获取资源后才再进行自我中断selfInterrupt（），将中断补上。
如今开始对这四个方法进行源码分析
1.1 tryAcquire(int)
protected boolean tryAcquire(int arg) {
throw new UnsupportedOperationException();
}
tryAcquire尝试以独占的方式获取资源，若是获取成功，则直接返回true，不然直接返回false。该方法能够用于实现Lock中的tryLock（）方法。该方法的默认实现是抛出UnsupportedOperationException异常，
什么？直接throw异常？说好的功能呢？好吧，还记得概述里讲的AQS只是一个框架，具体资源的获取/释放方式交由自定义同步器去实现吗？就是这里了！！！AQS这里只定义了一个接口，具体资源的获取交由
自定义同步器去实现了（经过state的get/set/CAS）！！！至于能不能重入，能不能加塞，那就看具体的自定义同步器怎么去设计了！！！固然，自定义同步器在进行资源访问时要考虑线程安全的影响。
这里之因此没有定义成abstract，是由于独占模式下只用实现tryAcquire-tryRelease，而共享模式下只用实现tryAcquireShared-tryReleaseShared。若是都定义成abstract，那么每一个模式也要去实现另外一模式下的接口。
说到底，Doug Lea仍是站在我们开发者的角度，尽可能减小没必要要的工做量。
1.2 addWaiter(Node)
/**
* Creates and enqueues node for current thread and given mode.
*
* @param mode Node.EXCLUSIVE for exclusive, Node.SHARED for shared
* @return the new node
*/
private Node addWaiter(Node mode) {
Node node = new Node(Thread.currentThread(), mode); //——以给定模式构造节点。mode有两种：EXCLUSIVE（独占）和SHARED（共享）
// Try the fast path of enq; backup to full enq on failure
Node pred = tail; //——尝试快速方式直接放到队尾
if (pred != null) {
node.prev = pred;
if (compareAndSetTail(pred, node)) {
pred.next = node;
return node;
}
}
enq(node); //——上一步失败则经过enq入队
return node;
}
不用再说了，直接看注释吧。这里咱们说下Node。Node结点是对每个访问同步代码的线程的封装，其包含了须要同步的线程自己以及线程的状态，如是否被阻塞，是否等待唤醒，是否已经被取消等。变量waitStatus则表示当前被封装成Node结点的等待状态，共有4种取值CANCELLED、SIGNAL、CONDITION、PROPAGATE。
CANCELLED：值为1，在同步队列中等待的线程等待超时或被中断，须要从同步队列中取消该Node的结点，其结点的waitStatus为CANCELLED，即结束状态，进入该状态后的结点将不会再变化。
SIGNAL：值为-1，被标识为该等待唤醒状态的后继结点，当其前继结点的线程释放了同步锁或被取消，将会通知该后继结点的线程执行。说白了，就是处于唤醒状态，只要前继结点释放锁，就会通知标识为SIGNAL状态的后继结点的线程执行。
CONDITION：值为-2，与Condition相关，该标识的结点处于等待队列中，结点的线程等待在Condition上，当其余线程调用了Condition的signal()方法后，CONDITION状态的结点将从等待队列转移到同步队列中，等待获取同步锁。
PROPAGATE：值为-3，与共享模式相关，在共享模式中，该状态标识结点的线程处于可运行状态。
0状态：值为0，表明初始化状态。
AQS在判断状态时，经过用waitStatus>0表示取消状态，而waitStatus<0表示有效状态。
1.2.1 enq(node)
/**
* Inserts node into queue, initializing if necessary. See picture above.
* @param node the node to insert
* @return node's predecessor
*/
private Node enq(final Node node) {
for (;;) { //——CAS自旋，直到成功加入队尾
Node t = tail;
if (t == null) { // Must initialize //——队列为空，建立一个空的标示节点做为head节点，并将tail也指向它
if (compareAndSetHead(new Node()))
tail = head;
} else { //——正常流程放入队尾
node.prev = t;
if (compareAndSetTail(t, node)) {
t.next = node;
return t;
}
}
}
}
enq(node)用于将当前节点插入到等待队列，若是队列为空，则初始化当前队列。整个过程以CAS自旋的方式进行，直到成功加入队尾为止。
1.3 acquireQueued(Node, int)
OK，经过tryAcquire()和addWaiter()，该线程获取资源失败，已经被放入等待队列尾部了。聪明的你马上应该能想到该线程下一部该干什么了吧：进入等待状态休息，直到其余线程完全释放资源后唤醒本身，本身再拿到资源，而后就能够去干本身想干的事了。没错，就是这样！是否是跟医院排队拿号有点类似~~acquireQueued()就是干这件事：在等待队列中排队拿号（中间没其它事干能够休息），直到拿到号后再返回。这个函数很是关键，仍是上源码吧：
final boolean acquireQueued(final Node node, int arg) {
boolean failed = true;//——标记是否成功拿到资源，默认是false
try {
boolean interrupted = false;//——标记等待过程是否被中断过
for (;;) { //——又是一个自旋！
final Node p = node.predecessor(); //——拿到前驱
if (p == head && tryAcquire(arg)) { //——若是前驱是head，即该节点已成为老二，那么便有资源去尝试获取资源（多是老大释放完资源后唤醒本身的，固然也可能被interrupt了）
setHead(node); //——拿到资源后，将head指向该节点。因此head所指向的标杆节点，就是当前获取到资源的那个节点或null
p.next = null; // help GC //setHead中的node.prev以置为null，此处再将head.next置为null，就是为了方便GC回收之前的head节点。也就意味着以前拿完资源的节点出队了！
failed = false;
return interrupted; //——返回等待过程当中是否被中断过
}
//若是本身能够休息了，就进入waiting状态，直到被unpark()
if (shouldParkAfterFailedAcquire(p, node) &&
parkAndCheckInterrupt())
interrupted = true; //若是等待过程被中断过了，哪怕只有那么一次，就将interrupted标记为true
}
} finally {
if (failed)
cancelAcquire(node);
}
}
到这里了，咱们先不急着总结acquireQueued()的函数流程，先看看shouldParkAfterFailedAcquire()和parkAndCheckInterrupt()具体干些什么。
1.3.1 shouldParkAfterFailedAcquire(Node, Node)
此方法主要用于检查状态，看看本身是否真的能够去休息了，进入waiting状态
private static boolean shouldParkAfterFailedAcquire(Node pred, Node node) {
int ws = pred.waitStatus; //——拿到前驱状态
if (ws == Node.SIGNAL) //——若是已经告诉前驱拿完号后通知本身一下，那就能够安心休息了
/*
* This node has already set status asking a release
* to signal it, so it can safely park.
*/
return true;
if (ws > 0) { //——若是前驱放弃了，那就一直往前找，直到找到一个最近正常等待的状态，并排在它的后边，注意哪些放弃的节点，因为被本身加塞到他们前边，他们至关于造成了一个无引用链，稍后GC回收。
/*
* Predecessor was cancelled. Skip over predecessors and
* indicate retry.
*/
do {
node.prev = pred = pred.prev;
} while (pred.waitStatus > 0);
pred.next = node;
} else {
/*
* waitStatus must be 0 or PROPAGATE. Indicate that we
* need a signal, but don't park yet. Caller will need to
* retry to make sure it cannot acquire before parking.
*/
compareAndSetWaitStatus(pred, ws, Node.SIGNAL); //——若是前驱正常，那就把前驱的状态设置为SIGNAL，告诉它拿完号后通知本身一下，有可能失败，人家说不定刚释放完呢！
}
return false;
}
整个流程中，若是前驱结点的状态不是SIGNAL，那么本身就不能安心去休息，须要去找个安心的休息点，同时能够再尝试下看有没有机会轮到本身拿号。
1.3.2 parkAndCheckInterrupt()
若是线程找好安全休息点后，那就能够安心去休息了。此方法就是让线程去休息，真正进入等待状态。
private final boolean parkAndCheckInterrupt() {
LockSupport.park(this);
return Thread.interrupted();
}
park()会让当前线程进入waiting状态。在此状态下，有两种途径能够唤醒该线程：1）被unpark()；2）被interrupt()。
1.3.3 小结
OK，看了shouldParkAfterFailedAcquire()和parkAndCheckInterrupt()，如今让咱们再回到acquireQueued()，总结下该函数的具体流程：
一、节点进入队尾后，检查状态，找到安全休息点
二、调用park()进入waiting状态，等待unpark()或interrupt（）唤醒本身
三、被唤醒后，看本身是否是有资格能拿到号。若是能拿到，head指向当前节点，并返回从入队到拿到号的整个过程当中是否被中断过；若是没用拿到，继续流程1
1.4 小结
OKOK，acquireQueued()分析完以后，咱们接下来再回到acquire()！再贴上它的源码吧：
public final void acquire(int arg) {
if (!tryAcquire(arg) &&
acquireQueued(addWaiter(Node.EXCLUSIVE), arg))
selfInterrupt();
}
再来总结下它的流程吧：
一、调用自定义同步器的tryAcquire（）尝试直接去获取资源，若是成功则直接返回；
二、没成功，则执行addWaiter（）将线程加入等待队列的尾部并标记为独占模式；
三、acquireQueued（）使线程在等待队列中休息，有机会时（轮到本身，会被unpark()）会去尝试获取资源。获取到资源才返回。若是在整个等待过程当中被中断过，则会返回true，不然返回false。
四、若是线程在等待过程当中被中断过，他是不响应的。只是获取资源后才进行自我中断selfInterrupt（），将中断补上。
因为此函数是重中之重，我再用流程图总结一下：
至此，acquire()的流程终于算是告一段落了。这也就是ReentrantLock.lock()的流程，不信你去看其lock()源码吧，整个函数就是一条acquire(1)！！！
2.release(int)
上一小节已经把acquire()说完了，这一小节就来说讲它的反操做release()吧。此方法是独占模式下线程释放共享资源的顶层入口。它会释放指定量的资源，
若是完全释放了（即state=0）,它会唤醒等待队列里的其余线程来获取资源。这也正是unlock()的语义，固然不只仅只限于unlock()。下面是release()的源码：
public final boolean release(int arg) {
if (tryRelease(arg)) {
Node h = head; //——找到头节点
if (h != null && h.waitStatus != 0)
unparkSuccessor(h); //——唤醒等待队列里的下一个线程
return true;
}
return false;
}
逻辑并不复杂。它调用tryRelease()来释放资源。有一点须要注意的是，它是根据tryRelease()的返回值来判断该线程是否已经完成释放掉资源了！因此自定义同步器在设计tryRelease()的时候要明确这一点！！
2.1 tryRelease(int)
此方法尝试去释放指定量的资源。下面是tryRelease()的源码：
protected boolean tryRelease(int arg) {
throw new UnsupportedOperationException();
}
跟tryAcquire()同样，这个方法是须要独占模式的自定义同步器去实现的。正常来讲，tryRelease()都会成功的，由于这是独占模式，该线程来释放资源，那么它确定已经拿到独占资源了，直接减掉相应量的资源便可(state-=arg)，也不须要考虑线程安全的问题。但要注意它的返回值，上面已经提到了，release()是根据tryRelease()的返回值来判断该线程是否已经完成释放掉资源了！因此自义定同步器在实现时，若是已经完全释放资源(state=0)，要返回true，不然返回false。
2.2 unparkSuccessor(Node)
此方法用于唤醒等待队列中下一个线程。下面是源码：
private void unparkSuccessor(Node node) {
int ws = node.waitStatus; //——这里node通常为当前线程所在的节点
if (ws < 0) //——置0当前线程所在的节点状态，容许失败
compareAndSetWaitStatus(node, ws, 0);
Node s = node.next; //——找到下一个须要唤醒的结点
if (s == null || s.waitStatus > 0) { //——若是为空，或已取消
s = null;
for (Node t = tail; t != null && t != node; t = t.prev)
if (t.waitStatus <= 0) //——这里看到<=0的结点，仍是有效的结点
s = t;
}
if (s != null)
LockSupport.unpark(s.thread); //——唤醒
}
这个函数并不复杂。一句话归纳：用unpark()唤醒等待队列中最前边的那个未放弃线程，这里咱们也用s来表示吧。此时，再和acquireQueued()联系起来，s被唤醒后，进入if (p == head && tryAcquire(arg))的判断（即便p!=head也不要紧，它会再进入shouldParkAfterFailedAcquire()寻找一个安全点。这里既然s已是等待队列中最前边的那个未放弃线程了，那么经过shouldParkAfterFailedAcquire()的调整，s也必然会跑到head的next结点，下一次自旋p==head就成立啦），而后s把本身设置成head标杆结点，表示本身已经获取到资源了，acquire()也返回了！！And then, DO what you WANT!
2.3 小结
release()是独占模式下线程释放共享资源的顶层入口。它会释放指定量的资源，若是完全释放了（即state=0）,它会唤醒等待队列里的其余线程来获取资源。
3.acquireShared(int)
此方法是共享模式下线程获取共享资源的顶层入口。它会获取指定量的资源，获取成功则直接返回，获取失败则进入等待队列，直到获取到资源为止，整个过程忽略中断。下面是acquireShared()的源码：
public final void acquireShared(int arg) {
if (tryAcquireShared(arg) < 0)
doAcquireShared(arg);
}
这里tryAcquireShared()依然须要自定义同步器去实现。可是AQS已经把其返回值的语义定义好了：负值表明获取失败；0表明获取成功，但没有剩余资源；正数表示获取成功，还有剩余资源，其余线程还能够去获取。因此这里acquireShared()的流程就是： tryAcquireShared()尝试获取资源，成功则直接返回； 失败则经过doAcquireShared()进入等待队列，直到获取到资源为止才返回。
3.1.doAcquireShared(int)
此方法用于将当前线程加入等待队列尾部休息，直到其余线程释放资源唤醒本身，本身成功拿到相应量的资源后才返回。下面是doAcquireShared()的源码：
private void doAcquireShared(int arg) {
final Node node = addWaiter(Node.SHARED); //——加入队列尾部
boolean failed = true; //——是否成功标志
try {
boolean interrupted = false; //——等待过程当中是否被中断的标志
for (;;) {
final Node p = node.predecessor(); //前驱
if (p == head) { //若是到head的下一个，由于head是拿到资源的线程，此时node被唤醒，极可能是head用完资源来唤醒本身
int r = tryAcquireShared(arg); //尝试获取资源
if (r >= 0) { //成功
setHeadAndPropagate(node, r); //将head指向本身，还有剩余资源能够再唤醒以后的线程
p.next = null; // help GC
if (interrupted) //若是等待过程当中被打断过，直接将中断补上
selfInterrupt();
failed = false;
return;
}
}
if (shouldParkAfterFailedAcquire(p, node) && //判断状态，寻找安全点，进入waiting状态，等被unpark()或interrupt（）
parkAndCheckInterrupt())
interrupted = true;
}
} finally {
if (failed)
cancelAcquire(node);
}
}
有木有以为跟acquireQueued()很类似？对，其实流程并无太大区别。只不过这里将补中断的selfInterrupt()放到doAcquireShared()里了，而独占模式是放到acquireQueued()以外，其实都同样，不知道Doug Lea是怎么想的。
跟独占模式比，还有一点须要注意的是，这里只有线程是head.next时（“老二”），才会去尝试获取资源，有剩余的话还会唤醒以后的队友。那么问题就来了，假如老大用完后释放了5个资源，而老二须要6个，老三须要1个，老四须要2个。老大先唤醒老二，老二一看资源不够，他是把资源让给老三呢，仍是不让？答案是否认的！老二会继续park()等待其余线程释放资源，也更不会去唤醒老三和老四了。独占模式，同一时刻只有一个线程去执行，这样作何尝不可；但共享模式下，多个线程是能够同时执行的，如今由于老二的资源需求量大，而把后面量小的老三和老四也都卡住了。固然，这并非问题，只是AQS保证严格按照入队顺序唤醒罢了（保证公平，但下降了并发）。
3.1.1 setHeadAndPropagate(Node, int)
private void setHeadAndPropagate(Node node, int propagate) {
Node h = head; // Record old head for check below
setHead(node); //head指向本身
//若是还有剩余资源，继续唤醒下一个邻居线程
if (propagate > 0 || h == null || h.waitStatus < 0 ||
(h = head) == null || h.waitStatus < 0) {
Node s = node.next;
if (s == null || s.isShared())
doReleaseShared();
}
}
此方法在setHead()的基础上多了一步，就是本身苏醒的同时，若是条件符合（好比还有剩余资源），还会去唤醒后继结点，毕竟是共享模式！
3.2 小结
OK，至此，acquireShared()也要告一段落了。让咱们再梳理一下它的流程：
- tryAcquireShared()尝试获取资源，成功则直接返回；
- 失败则经过doAcquireShared()进入等待队列park()，直到被unpark()/interrupt()并成功获取到资源才返回。整个等待过程也是忽略中断的。
其实跟acquire()的流程大同小异，只不过多了个本身拿到资源后，还会去唤醒后继队友的操做（这才是共享嘛）。
4. releaseShared(int)
上一小节已经把acquireShared()说完了，这一小节就来说讲它的反操做releaseShared()吧。此方法是共享模式下线程释放共享资源的顶层入口。它会释放指定量的资源，若是成功释放且容许唤醒等待线程，它会唤醒等待队列里的其余线程来获取资源。下面是releaseShared()的源码：
public final boolean releaseShared(int arg) {
if (tryReleaseShared(arg)) { //尝试释放资源
doReleaseShared(); //唤醒后继结点
return true;
}
return false;
}
此方法的流程也比较简单，一句话：释放掉资源后，唤醒后继。跟独占模式下的release()类似，但有一点稍微须要注意：独占模式下的tryRelease()在彻底释放掉资源（state=0）后，才会返回true去唤醒其余线程，这主要是基于独占下可重入的考量；而共享模式下的releaseShared()则没有这种要求，共享模式实质就是控制必定量的线程并发执行，那么拥有资源的线程在释放掉部分资源时就能够唤醒后继等待结点。例如，资源总量是13，A（5）和B（7）分别获取到资源并发运行，C（4）来时只剩1个资源就须要等待。A在运行过程当中释放掉2个资源量，而后tryReleaseShared(2)返回true唤醒C，C一看只有3个仍不够继续等待；随后B又释放2个，tryReleaseShared(2)返回true唤醒C，C一看有5个够本身用了，而后C就能够跟A和B一块儿运行。而ReentrantReadWriteLock读锁的tryReleaseShared()只有在彻底释放掉资源（state=0）才返回true，因此自定义同步器能够根据须要决定tryReleaseShared()的返回值。
4.1 doReleaseShared（）
此方法主要用于唤醒后继。下面是它的源码：
private void doReleaseShared() {
for (;;) {
Node h = head;
if (h != null && h != tail) {
int ws = h.waitStatus;
if (ws == Node.SIGNAL) {
if (!compareAndSetWaitStatus(h, Node.SIGNAL, 0))
continue;// loop to recheck cases
unparkSuccessor(h); //唤醒后继
}
else if (ws == 0 &&
!compareAndSetWaitStatus(h, 0, Node.PROPAGATE))
continue; // loop on failed CAS
}
if (h == head) //head发生变化
break;
}
}
5 小结
本节咱们详解了独占和共享两种模式下获取-释放资源(acquire-release、acquireShared-releaseShared)的源码，相信你们都有必定认识了。值得注意的是，acquire()和acquireShared()两种方法下，线程在等待队列中都是忽略中断的。AQS也支持响应中断的，acquireInterruptibly()/acquireSharedInterruptibly()便是，这里相应的源码跟acquire()和acquireShared()差很少，这里就再也不详解了。
4、简单应用
4.1 Mutex（互斥锁）
Mutex是一个不可重入的互斥锁实现。锁资源（AQS里的state）只有两种状态：0表示未锁定，1表示锁定。下边是Mutex的核心源码：
class Mutex implements Lock, java.io.Serializable {
// 自定义同步器
private static class Sync extends AbstractQueuedSynchronizer {
// 判断是否锁定状态
protected boolean isHeldExclusively() {
return getState() == 1;
}
// 尝试获取资源，当即返回。成功则返回true，不然false。
public boolean tryAcquire(int acquires) {
assert acquires == 1; // 这里限定只能为1个量
if (compareAndSetState(0, 1)) {//state为0才设置为1，不可重入！
setExclusiveOwnerThread(Thread.currentThread());//设置为当前线程独占资源
return true;
}
return false;
}
// 尝试释放资源，当即返回。成功则为true，不然false。
protected boolean tryRelease(int releases) {
assert releases == 1; // 限定为1个量
if (getState() == 0)//既然来释放，那确定就是已占有状态了。只是为了保险，多层判断！
throw new IllegalMonitorStateException();
setExclusiveOwnerThread(null);
setState(0);//释放资源，放弃占有状态
return true;
}
}
// 真正同步类的实现都依赖继承于AQS的自定义同步器！
private final Sync sync = new Sync();
//lock<-->acquire。二者语义同样：获取资源，即使等待，直到成功才返回。
public void lock() {
sync.acquire(1);
}
//tryLock<-->tryAcquire。二者语义同样：尝试获取资源，要求当即返回。成功则为true，失败则为false。
public boolean tryLock() {
return sync.tryAcquire(1);
}
//unlock<-->release。二者语文同样：释放资源。
public void unlock() {
sync.release(1);
}
//锁是否占有状态
public boolean isLocked() {
return sync.isHeldExclusively();
}
}
同步类在实现时通常都将自定义同步器（sync）定义为内部类，供本身使用；而同步类本身（Mutex）则实现某个接口，对外服务。固然，接口的实现要直接依赖sync，它们在语义上也存在某种对应关系！！而sync只用实现资源state的获取-释放方式tryAcquire-tryRelelase，至于线程的排队、等待、唤醒等，上层的AQS都已经实现好了，咱们不用关心。
除了Mutex，ReentrantLock/CountDownLatch/Semphore这些同步类的实现方式都差很少，不一样的地方就在获取-释放资源的方式tryAcquire-tryRelelase。掌握了这点，AQS的核心便被攻破了！
OK，至此，整个AQS的讲解也要落下帷幕了。
参考书籍
Java并发编程之美
参考连接
- 1. AbstractQueuedSynchronizer 队列同步器（AQS）
- 2. java-AQS(抽象队列同步器)
- 3. 浅谈AQS（抽象队列同步器）
- 4. 抽象队列同步器AQS
- 5. java中的队列同步器AQS -- AbstractQueuedSynchronizer
- 6. java 队列同步器AbstractQueuedSynchronizer（AQS）
- 7. 手写Lock锁与AQS抽象队列同步器
- 8. AbstractQueuedSynchronizer抽象队列同步器的简单理解
- 9. AQS: 等待队列详解（AbstractQueuedSynchronizer）
- 10. java AQS（AbstractQueuedSynchronizer）同步器详解
- 更多相关文章...
- • C# 队列（Queue） - C#教程
- • MySQL下载步骤详解 - MySQL教程
- • Flink 数据传输及反压详解
- • 漫谈MySQL的锁机制
-
每一个你不满意的现在，都有一个你没有努力的曾经。
- 1. 安装cuda+cuDNN
- 2. GitHub的使用说明
- 3. phpDocumentor使用教程【安装PHPDocumentor】
- 4. yarn run build报错Component is not found in path “npm/taro-ui/dist/weapp/components/rate/index“
- 5. 精讲Haproxy搭建Web集群
- 6. 安全测试基础之MySQL
- 7. C/C++编程笔记：C语言中的复杂声明分析，用实例带你完全读懂
- 8. Python3教程(1)----搭建Python环境
- 9. 李宏毅机器学习课程笔记2：Classification、Logistic Regression、Brief Introduction of Deep Learning
- 10. 阿里云ECS配置速记
- 1. AbstractQueuedSynchronizer 队列同步器（AQS）
- 2. java-AQS(抽象队列同步器)
- 3. 浅谈AQS（抽象队列同步器）
- 4. 抽象队列同步器AQS
- 5. java中的队列同步器AQS -- AbstractQueuedSynchronizer
- 6. java 队列同步器AbstractQueuedSynchronizer（AQS）
- 7. 手写Lock锁与AQS抽象队列同步器
- 8. AbstractQueuedSynchronizer抽象队列同步器的简单理解
- 9. AQS: 等待队列详解（AbstractQueuedSynchronizer）
- 10. java AQS（AbstractQueuedSynchronizer）同步器详解