专注Java领域优质技术，欢迎关注。
作者：Ccww
序
你觉得在工作中很难升职吗？你觉得找工作面试这么难吗？有没有感觉每天加班996？
你必须在工作中保持学习的能力，这样你才能在工作中得到更好的提升，加薪指日可待。欢迎一起学习【提升能力，涨薪可待】系列求职面试。你要在学习的基础上总结面试知识点，工作指日可待。欢迎一起学习【面试知识，工作可待】系列。最后，理论知识准备充分。该不该付诸实践？欢迎一起学习【实战演练，拒绝996】系列。
AQS全称AbstractQueuedSynchronizer，是一个用来构建锁和同步器的框架。
基于AQS构建同步器：
优势：
AQ解决了同步器实现中涉及到的很多细节，比如自定义标准同步状态、FIFO同步队列等。基于AQS构建同步器可以带来很多好处。它不仅可以大大减少实施工作，而且不必处理多个地点的竞争。
2.1 AQS的核心思想
如果所请求的共享资源是空闲的，则当前请求该资源的线程被设置为有效的工作线程，并且共享资源被设置为锁定状态。如果所请求的共享资源被占用，那么就需要一种线程阻塞等待和唤醒时锁分配的机制。这种机制AQS是通过CLH队列锁实现的，即将暂时不能获得锁的线程加入队列。如图所示：
Sync queue：同步队列是双向列表。包括头节点和尾节点。头节点主要用于后续调度。
Condition queue：可选，单向列表。只有当程序中存在实例时，该列表才存在。
2.2 AQS设计思想
AQS使用一个int成员变量来表示同步状态。使用节点实现FIFO队列可以用来建立锁或其他同步设备。AQS资源共享方式：独占锁模式和共享锁模式。在它的所有子类中，AQS要么实现并使用它的独占api，要么使用共享锁函数，而不是同时使用两套API。即使是最著名的子类ReentrantReadWriteLock，也是通过在两个内部类中实现两组API来实现的，即读锁和写锁。
2.3国家地位
State使用volatile int类型的变量来指示当前同步状态。有三种方法可以访问状态：3360
getstate()setstate()compareandsetstate()2.4 aqs中节点常量的含义
当CANCELLED的waitstatus值为1时，表示线程节点已经被释放(超时、中断)，被取消的节点不会再被阻塞。
当SIGNALwait status为-1时，表示该线程的后续线程需要被阻塞，即只要前面的节点释放锁，就会通知后续节点的线程标识为信号状态。
当CONDITION等待状态为-2时，意味着线程在条件队列中被阻塞(条件被使用)
当PROPAGATEwait status为-3时，表示处于PROPAGATE状态的线程在本线程和后续线程无条件传播(用于CountDownLatch)的共享模式下处于runnable状态。
2.5同步队列为什么叫FIFO？
因为只有其前趋节点是头节点的节点才能首先被唤醒以获得同步状态。当节点获得同步状态时，它将清除自己的值，并使用自己作为头节点，以便唤醒下一个节点。
2.6条件队列
除了同步队列之外，在AQS中还有一种条件队列，这是一种单向队列。调用ConditionObject.await()方法可以将当前线程封装成一个节点，添加到c中。
ondition队列的末尾，然后将获取的同步状态释放（即修改同步状态的值，唤醒在同步队列中的线程）。Condition队列也是FIFO。调用ConditionObject.signal()方法，能够唤醒firstWaiter节点，将其添加到同步队列末尾。
2.7 自定义同步器的实现
在构建自定义同步器时，只需要依赖AQS底层再实现共享资源state的获取与释放操作即可。自定义同步器实现时主要实现以下几种方法：
isHeldExclusively()：该线程是否正在独占资源。只有用到condition才需要去实现它。tryAcquire(int)：独占方式。尝试获取资源，成功则返回true，失败则返回false。tryRelease(int)：独占方式。尝试释放资源，成功则返回true，失败则返回false。tryAcquireShared(int)：共享方式。尝试获取资源。负数表示失败；0表示成功，但没有剩余可用资源；正数表示成功，且有剩余资源。tryReleaseShared(int)：共享方式。尝试释放资源，如果释放后允许唤醒后续等待结点返回true，否则返回false。
3.1 独占模式下的AQS
所谓独占模式，即只允许一个线程获取同步状态，当这个线程还没有释放同步状态时，其他线程是获取不了的，只能加入到同步队列，进行等待。
很明显，我们可以将state的初始值设为0，表示空闲。当一个线程获取到同步状态时，利用CAS操作让state加1，表示非空闲，那么其他线程就只能等待了。释放同步状态时，不需要CAS操作，因为独占模式下只有一个线程能获取到同步状态。ReentrantLock、CyclicBarrier正是基于此设计的。
例如，ReentrantLock，state初始化为0，表示未锁定状态。A线程lock()时，会调用tryAcquire()独占该锁并将state+1。
独占模式下的AQS是不响应中断的，指的是加入到同步队列中的线程，如果因为中断而被唤醒的话，不会立即返回，并且抛出InterruptedException。而是再次去判断其前驱节点是否为head节点，决定是否争抢同步状态。如果其前驱节点不是head节点或者争抢同步状态失败，那么再次挂起。
3.1.1 独占模式获取资源-acquire方法
acquire以独占exclusive方式获取资源。如果获取到资源，线程直接返回，否则进入等待队列，直到获取到资源为止，且整个过程忽略中断的影响。源码如下：
public final void acquire(int arg) { if (!tryAcquire(arg) && acquireQueued(addWaiter(Node.EXCLUSIVE), arg)) selfInterrupt(); }流程图：
调用自定义同步器的tryAcquire()尝试直接去获取资源，如果成功则直接返回；没成功，则addWaiter()将该线程加入等待队列的尾部，并标记为独占模式；acquireQueued()使线程在等待队列中休息，有机会时（轮到自己，会被unpark()）会去尝试获取资源。获取到资源后才返回。如果在整个等待过程中被中断过，则返回true，否则返回false。如果线程在等待过程中被中断过，它是不响应的。只是获取资源后才再进行自我中断selfInterrupt()，将中断补上。3.1.2 独占模式获取资源-tryAcquire方法
tryAcquire尝试以独占的方式获取资源，如果获取成功，则直接返回true，否则直接返回false，且具体实现由自定义AQS的同步器实现的。
protected boolean tryAcquire(int arg) { throw new UnsupportedOperationException(); }3.1.3 独占模式获取资源-addWaiter方法
根据不同模式(Node.EXCLUSIVE互斥模式、Node.SHARED共享模式)创建结点并以CAS的方式将当前线程节点加入到不为空的等待队列的末尾(通过compareAndSetTail()方法)。如果队列为空，通过enq(node)方法初始化一个等待队列，并返回当前节点。
/*** 参数* @param mode Node.EXCLUSIVE for exclusive, Node.SHARED for shared* 返回值* @return the new node*/private Node addWaiter(Node mode) { //将当前线程以指定的模式创建节点node Node node = new Node(Thread.currentThread(), mode); // Try the fast path of enq; backup to full enq on failure // 获取当前同队列的尾节点 Node pred = tail; //队列不为空，将新的node加入等待队列中 if (pred != null) { node.prev = pred; //CAS方式将当前节点尾插入队列中 if (compareAndSetTail(pred, node)) { pred.next = node; return node; } } //当队列为empty或者CAS失败时会调用enq方法处理 enq(node); return node;}其中，队列为empty，使用enq(node)处理，将当前节点插入等待队列，如果队列为空，则初始化当前队列。所有操作都是CAS自旋的方式进行，直到成功加入队尾为止。
private Node enq(final Node node) { //不断自旋 for (;;) { Node t = tail; //当前队列为empty if (t == null) { // Must initialize //完成队列初始化操作，头结点中不放数据，只是作为起始标记，lazy-load，在第一次用的时候new if (compareAndSetHead(new Node())) tail = head; } else { node.prev = t; //不断将当前节点使用CAS尾插入队列中直到成功为止 if (compareAndSetTail(t, node)) { t.next = node; return t; } } } }3.1.4 独占模式获取资源-acquireQueued方法
acquireQueued用于已在队列中的线程以独占且不间断模式获取state状态，直到获取锁后返回。主要流程：
结点node进入队列尾部后，检查状态；调用park()进入waiting状态，等待unpark()或interrupt()唤醒；被唤醒后，是否获取到锁。如果获取到，head指向当前结点，并返回从入队到获取锁的整个过程中是否被中断过；如果没获取到，继续流程1 final boolean acquireQueued(final Node node, int arg) { //是否已获取锁的标志，默认为true 即为尚未 boolean failed = true; try { //等待中是否被中断过的标记 boolean interrupted = false; for (;;) { //获取前节点 final Node p = node.predecessor(); //如果当前节点已经成为头结点，尝试获取锁（tryAcquire）成功，然后返回 if (p == head && tryAcquire(arg)) { setHead(node); p.next = null; // help GC failed = false; return interrupted; } //shouldParkAfterFailedAcquire根据对当前节点的前一个节点的状态进行判断，对当前节点做出不同的操作 //parkAndCheckInterrupt让线程进入等待状态，并检查当前线程是否被可以被中断 if (shouldParkAfterFailedAcquire(p, node) && parkAndCheckInterrupt()) interrupted = true; } } finally { //将当前节点设置为取消状态；取消状态设置为1 if (failed) cancelAcquire(node); } } 复制代码3.1.5 独占模式释放资源-release方法
release方法是独占exclusive模式下线程释放共享资源的锁。它会调用tryRelease()释放同步资源，如果全部释放了同步状态为空闲（即state=0）,当同步状态为空闲时，它会唤醒等待队列里的其他线程来获取资源。这也正是unlock()的语义，当然不仅仅只限于unlock().
public final boolean release(int arg) { if (tryRelease(arg)) { Node h = head; if (h != null && h.waitStatus != 0) unparkSuccessor(h); return true; } return false; }3.1.6 独占模式释放资源-tryRelease方法
tryRelease()跟tryAcquire()一样实现都是由自定义定时器以独占exclusive模式实现的。因为其是独占模式，不需要考虑线程安全的问题去释放共享资源，直接减掉相应量的资源即可(state-=arg)。而且tryRelease()的返回值代表着该线程是否已经完成资源的释放，因此在自定义同步器的tryRelease()时，需要明确这条件，当已经彻底释放资源(state=0)，要返回true，否则返回false。
protected boolean tryRelease(int arg) { throw new UnsupportedOperationException(); }ReentrantReadWriteLock的实现：
protected final boolean tryRelease(int releases) { if (!isHeldExclusively()) throw new IllegalMonitorStateException(); //减掉相应量的资源(state-=arg) int nextc = getState() - releases; //是否完全释放资源 boolean free = exclusiveCount(nextc) == 0; if (free) setExclusiveOwnerThread(null); setState(nextc); return free; }3.1.7 独占模式释放资源-unparkSuccessor
unparkSuccessor用unpark()唤醒等待队列中最前驱的那个未放弃线程，此线程并不一定是当前节点的next节点，而是下一个可以用来唤醒的线程，如果这个节点存在，调用unpark()方法唤醒。
private void unparkSuccessor(Node node) { //当前线程所在的结点node int ws = node.waitStatus; //置零当前线程所在的结点状态，允许失败 if (ws < 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) //从这里可以看出，<=0的结点，都是还有效的结点 if (t.waitStatus <= 0) s = t; } if (s != null) //唤醒 LockSupport.unpark(s.thread);}3.2 共享模式下的AQS
共享模式，当然是允许多个线程同时获取到同步状态,共享模式下的AQS也是不响应中断的.
很明显，我们可以将state的初始值设为N（N > 0），表示空闲。每当一个线程获取到同步状态时，就利用CAS操作让state减1，直到减到0表示非空闲，其他线程就只能加入到同步队列，进行等待。释放同步状态时，需要CAS操作，因为共享模式下，有多个线程能获取到同步状态。CountDownLatch、Semaphore正是基于此设计的。
例如，CountDownLatch，任务分为N个子线程去执行，同步状态state也初始化为N（注意N要与线程个数一致）：
3.2.1 共享模式获取资源-acquireShared方法
acquireShared在共享模式下线程获取共享资源的顶层入口。它会获取指定量的资源，获取成功则直接返回，获取失败则进入等待队列，直到获取到资源为止，整个过程忽略中断。
public final void acquireShared(int arg) { if (tryAcquireShared(arg) < 0) doAcquireShared(arg);}流程：
先通过tryAcquireShared()尝试获取资源，成功则直接返回；失败则通过doAcquireShared()中的park()进入等待队列，直到被unpark()/interrupt()并成功获取到资源才返回(整个等待过程也是忽略中断响应)。3.2.2 共享模式获取资源-tryAcquireShared方法
tryAcquireShared()跟独占模式获取资源方法一样实现都是由自定义同步器去实现。但AQS规范中已定义好tryAcquireShared()的返回值：
负值代表获取失败；0代表获取成功，但没有剩余资源；正数表示获取成功，还有剩余资源，其他线程还可以去获取。 protected int tryAcquireShared(int arg) { throw new UnsupportedOperationException(); }3.2.3 共享模式获取资源-doAcquireShared方法
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; } } //判断状态，队列寻找一个适合位置，进入waiting状态，等着被unpark()或interrupt() if (shouldParkAfterFailedAcquire(p, node) && parkAndCheckInterrupt()) interrupted = true; } } finally { if (failed) cancelAcquire(node); } }3.2.4 共享模式释放资源-releaseShared方法
releaseShared()用于共享模式下线程释放共享资源，释放指定量的资源，如果成功释放且允许唤醒等待线程，它会唤醒等待队列里的其他线程来获取资源。
public final boolean releaseShared(int arg) { //尝试释放资源 if (tryReleaseShared(arg)) { //唤醒后继结点 doReleaseShared(); return true; } return false;}独占模式下的tryRelease()在完全释放掉资源（state=0）后，才会返回true去唤醒其他线程，这主要是基于独占下可重入的考量；而共享模式下的releaseShared()则没有这种要求，共享模式实质就是控制一定量的线程并发执行，那么拥有资源的线程在释放掉部分资源时就可以唤醒后继等待结点。https://www.cnblogs.com/waterystone/p/4920797.html
3.2.共享模式释放资源-doReleaseShared方法
doReleaseShared()主要用于唤醒后继节点线程,当state为正数，去获取剩余共享资源；当state=0时去获取共享资源。
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; //唤醒后继 unparkSuccessor(h); } else if (ws == 0 && !compareAndSetWaitStatus(h, 0, Node.PROPAGATE)) continue; } // head发生变化 if (h == head) break; }}来源：掘金 链接：https://juejin.im/post/5dc3db9a5188257bda21cac
