【搞定Java并发编程】第17篇：队列同步器AQS源码分析之共享模式

小咪咪 2022-04-05 15:35 100阅读 0赞

**AQS系列文章：**

**[1、队列同步器AQS源码分析之概要分析][1_AQS]**

**[2、队列同步器AQS源码分析之独占模式][2_AQS]**

**[3、队列同步器AQS源码分析之共享模式][3_AQS]**

**[4、队列同步器AQS源码分析之Condition接口、等待队列][4_AQS_Condition]**

--------------------

通过上一篇文章的的分析，我们知道独占模式获取同步状态（或者说获取锁）有三种方式，分别是：**独占式同步状态获取（不响应中断）、独占式同步状态获取（响应中断）**和**超时获取同步状态**。

在共享模式下获取同步状态的方式也是这三种，而且基本上大同小异，理解其中一种很快就能弄明白另一种了。

**共享模式获取同步状态与独占模式获取同步状态最主要的区别在于同一时刻能否有多个线程同时获取同步状态**。以文件为例，如果一个程序在对文件进行读操作，那么这一时刻对于该文件的写操作均被阻塞，而读操作可以同时进行。学操作要求对资源的独占式访问，而读操作可以是共享式访问。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Bjd2wxMjA2_size_16_color_FFFFFF_t_70][]**共享式与独占式访问资源的对比**

--------------------

# 1、共享式获取同步状态（不响应中断） #

通过调用同步器的acquireShared(int  arg)方法可以共享式地获取同步状态。该方法的源码如下：

public final void acquireShared(int arg) {
        // 1.尝试去获取同步状态
        if (tryAcquireShared(arg) < 0) {
            // 2.如果获取失败就进入这个方法
            doAcquireShared(arg);
        }
    }
    
    // 尝试去获取同步状态(共享模式)
    // 负数：表示获取失败
    // 零值：表示当前结点获取成功, 但是后继结点不能再获取了
    // 正数：表示当前结点获取成功, 并且后继结点同样可以获取成功
    protected int tryAcquireShared(int arg) {
        throw new UnsupportedOperationException();
    }

调用acquireShared()方法是不响应线程中断共享式获取同步状态的方式。在该方法中，首先调用tryAcquireShared去尝试获取同步状态，tryAcquireShared方法返回一个获取同步的状态。这里AQS规定了返回状态若是负数代表当前结点获取同步状态失败，若是0代表当前结点获取同步状态成功，但后继结点不能再获取了，若是正数则代表当前结点获取同步状态成功，并且这个同步状态后续结点也同样可以获取成功。

自定义子类在实现tryAcquireShared方法获取同步状态的逻辑时，返回值需要遵守这个约定。如果调用tryAcquireShared的返回值小于0，就代表这次尝试获取同步状态失败了，接下来就调用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();
                // 如果前继结点为head结点就再次尝试去获取锁
                if (p == head) {
                    // 再次尝试去获取同步状态并返回获取状态
                    // r < 0, 表示获取失败
                    // r = 0, 表示当前结点获取成功, 但是后继结点不能再获取了
                    // r > 0, 表示当前结点获取成功, 并且后继结点同样可以获取成功
                    int r = tryAcquireShared(arg);
                    if (r >= 0) {
                        // 到这里说明当前结点已经获取同步状态成功了, 此时它会将锁的状态信息传播给后继结点
                        setHeadAndPropagate(node, r);
                        p.next = null;
                        // 如果在线程阻塞期间收到中断请求, 就在这一步响应该请求
                        if (interrupted) {
                            selfInterrupt();
                        }
                        failed = false;
                        return;
                    }
                }
                // 每次获取锁失败后都会判断是否可以将线程挂起, 
                // 如果可以的话就会在parkAndCheckInterrupt方法里将线程挂起
                if (shouldParkAfterFailedAcquire(p, node) && parkAndCheckInterrupt()) {
                    interrupted = true;
                }
            }
        } finally {
            if (failed) {
                cancelAcquire(node);
            }
        }
    }

进入doAcquireShared方法首先是调用addWaiter方法将当前线程包装成节点放到同步队列尾部。这个添加节点的过程我们在讲独占模式时讲过，这里就不再讲了。

节点进入同步队列后，如果它发现在它前面的节点就是head结点，因为head结点的线程已经获取同步状态了，那么下一个获取同步状态的节点就轮到自己了，所以当前节点先不会将自己挂起，而是再一次去尝试获取同步状态，如果前面的节点刚好释放锁离开了，那么当前节点就能成功获得锁。

如果前面那个节点还没有释放锁，那么就会调用shouldParkAfterFailedAcquire方法，在这个方法里面会将head节点的状态改为SIGNAL，只有保证前面节点的状态为SIGNAL，当前节点才能放心的将自己挂起，所有线程都会在parkAndCheckInterrupt方法里面被挂起。

如果当前节点恰巧成功的获取了锁，那么接下来就会调用setHeadAndPropagate方法将自己设置为head节点，并且唤醒后面同样是共享模式的节点。下面我们看下setHeadAndPropagate方法具体的操作。

private void setHeadAndPropagate(Node node, int propagate) {
        Node h = head;
        // 将给定结点设置为head结点
        setHead(node);
        // 如果propagate大于0表明锁可以获取了
        if (propagate > 0 || h == null || h.waitStatus < 0) {
            // 获取给定结点的后继结点
            Node s = node.next;
            // 如果给定结点的后继结点为空, 或者它的状态是共享状态
            if (s == null || s.isShared()) {
                // 唤醒后继结点
                doReleaseShared();
            }
        }
    }
    
    //释放同步状态的操作(共享模式)
    private void doReleaseShared() {
        for (;;) {
            // 获取同步队列的head结点
            Node h = head;
            if (h != null && h != tail) {
                // 获取head结点的等待状态
                int ws = h.waitStatus;
                // 如果head结点的状态为SIGNAL, 表明后面有人在排队
                if (ws == Node.SIGNAL) {
                    // 先把head结点的等待状态更新为0
                    if (!compareAndSetWaitStatus(h, Node.SIGNAL, 0)) {
                        continue;
                    }
                    // 再去唤醒后继结点
                    unparkSuccessor(h);
                 // 如果head结点的状态为0, 表明此时后面没人在排队, 就只是将head状态修改为PROPAGATE
                }else if (ws == 0 && !compareAndSetWaitStatus(h, 0, Node.PROPAGATE)) {
                    continue;
                }
            }
            // 只有保证期间head结点没被修改过才能跳出循环
            if (h == head) {
                break;
            }
        }
    }

调用setHeadAndPropagate方法首先将自己设置成head节点，然后再根据传入的tryAcquireShared方法的返回值来决定是否要去唤醒后继节点。

前面已经讲到当返回值大于0就表明当前节点成功获取了同步状态，并且后面的节点也可以成功获取同步状态。这时当前节点就需要去唤醒后面同样是共享模式的节点，注意，每次唤醒仅仅只是唤醒后一个节点，如果后一个节点不是共享模式的话，当前节点就不会再去唤醒更后面的节点了。

共享模式下唤醒后继节点的操作是在doReleaseShared方法进行的，共享模式和独占模式的唤醒操作基本也是相同的，都是去找到自己座位上的牌子(等待状态)，如果牌子上为SIGNAL表明后面有人需要让它帮忙唤醒，如果牌子上为0则表明队列此时并没有节点在排队。

在独占模式下是如果发现没节点在排队就直接离开队列了，而在共享模式下如果发现队列后面没节点在排队，当前节点在离开前仍然会留个小纸条(将等待状态设置为PROPAGATE)告诉后来的人这个锁的可获取状态。那么后面来的人在尝试获取锁的时候可以根据这个状态来判断是否直接获取锁。

--------------------

# 2、共享式获取同步状态（响应中断） #

响应中断操作的共享模式下获取同步状态是调用同步器中的acquireSharedInterruptibly(int  arg)方法。

public final void acquireSharedInterruptibly(int arg) throws InterruptedException {
        // 首先判断线程是否中断, 如果是则抛出异常
        if (Thread.interrupted()) {
            throw new InterruptedException();
        }
        // 1.尝试去获取同步状态
        if (tryAcquireShared(arg) < 0) {
            // 2. 如果获取失败则进人该方法
            doAcquireSharedInterruptibly(arg);
        }
    }
    
    // 以可中断模式获取同步状态(共享模式)
    private void doAcquireSharedInterruptibly(int arg) throws InterruptedException {
        // 将当前节点插入同步队列尾部
        final Node node = addWaiter(Node.SHARED);
        boolean failed = true;
        try {
            for (;;) {
                // 获取当前节点的前驱节点
                final Node p = node.predecessor();
                if (p == head) {
                    // 1.如果node的前驱结点是头节点，则node尝试获取同步状态
                    int r = tryAcquireShared(arg);
                    // 2.如果获取到同步状态
                    if (r >= 0) {
                        setHeadAndPropagate(node, r);
                        p.next = null;
                        failed = false;
                        return;
                    }
                }
                if (shouldParkAfterFailedAcquire(p, node) && parkAndCheckInterrupt()) {
                    // 如果线程在阻塞过程中收到过中断请求, 那么就会立马在这里抛出异常
                    throw new InterruptedException();
                }
            }
        } finally {
            if (failed) {
                cancelAcquire(node);
            }
        }
    }

共享模式下响应线程中断获取同步状态的方式和不响应线程中断获取同步状态的方式在流程上基本是相同的，唯一的区别就是在哪里响应线程的中断请求。

在不响应线程中断获取同步状态时，线程从parkAndCheckInterrupt方法中被唤醒，唤醒后就立马返回是否收到中断请求，即使是收到了中断请求也会继续自旋直到获取同步状态后才响应中断请求将自己给挂起。而响应线程中断获取同步状态会在线程被唤醒后立马响应中断请求，如果在阻塞过程中收到了线程中断就会立马抛出InterruptedException异常。

--------------------

# 3、共享式超时获取同步状态 #

共享式超时获取同步状态需要调用同步器AQS抽象类中的tryAcquireSharedNanos(int  arg, long  nanosTimeout)方法，该方法的调用过程如下：

public final boolean tryAcquireSharedNanos(int arg, long nanosTimeout) throws InterruptedException {
        if (Thread.interrupted()) {
            throw new InterruptedException();
        }
        // 1.调用tryAcquireShared尝试去获取同步状态
        // 2.如果获取失败就调用doAcquireSharedNanos
        return tryAcquireShared(arg) >= 0 || doAcquireSharedNanos(arg, nanosTimeout);
    }
    
    // 以限定超时时间获取同步状态(共享模式)
    private boolean doAcquireSharedNanos(int arg, long nanosTimeout) throws InterruptedException {
        long lastTime = System.nanoTime();
        final Node node = addWaiter(Node.SHARED);
        boolean failed = true;
        try {
            for (;;) {
                // 获取当前节点的前驱节点
                final Node p = node.predecessor();
                // 判断当前结点的前驱节点是否是头节点
                if (p == head) {
                    // 如果是头节点，则尝试获取同步状态，并返回int状态值
                    int r = tryAcquireShared(arg);
                    if (r >= 0) {
                        setHeadAndPropagate(node, r);
                        p.next = null;
                        failed = false;
                        return true;
                    }
                }
                // 如果超时时间用完了就结束获取, 并返回失败信息
                if (nanosTimeout <= 0) {
                    return false;
                }
                // 1.检查是否满足将线程挂起要求(保证前继结点状态为SIGNAL)
                // 2.检查超时时间是否大于自旋时间
                if (shouldParkAfterFailedAcquire(p, node) && nanosTimeout > spinForTimeoutThreshold) {
                    // 若满足上面两个条件就将当前线程挂起一段时间
                    LockSupport.parkNanos(this, nanosTimeout);
                }
                long now = System.nanoTime();
                // 超时时间每次减去获取同步状态的时间
                nanosTimeout -= now - lastTime;
                lastTime = now;
                // 如果在阻塞时收到中断请求就立马抛出异常
                if (Thread.interrupted()) {
                    throw new InterruptedException();
                }
            }
        } finally {
            if (failed) {
                cancelAcquire(node);
            }
        }
    }

如果看懂了上面两种获取方式，再来看设置超时时间的获取方式就会很轻松，基本流程都是一样的，主要是理解超时的机制是怎样的。

如果第一次获取同步状态失败会调用doAcquireSharedNanos方法并传入超时时间，进入方法后会根据情况再次去获取同步状态，如果再次获取失败就要考虑将线程挂起了。

这时会判断超时时间是否大于自旋时间，如果是的话就会将线程挂起一段时间，否则就继续尝试获取，每次获取锁之后都会将超时时间减去获取同步状态的时间，一直这样循环直到超时时间用尽，如果还没有获取到锁的话就会结束获取并返回获取失败标识。在整个期间线程是响应线程中断的。

--------------------

# 4、共享式同步状态的释放 #

与独占式一样，共享式获取也需要释放同步状态，通过调用realeaseShared(int  arg)方法可以释放同步状态，源码分析如下：

public final boolean releaseShared(int arg) {
        // 1.尝试去释放同步状态
        if (tryReleaseShared(arg)) {
            // 2.如果释放成功就唤醒其他线程
            doReleaseShared();
            return true;
        }
        return false;
    }
    
    // 尝试去释放同步状态(共享模式)
    protected boolean tryReleaseShared(int arg) {
        throw new UnsupportedOperationException();
    }
    
    // 释放同步状态的操作(共享模式)
    private void doReleaseShared() {
        for (;;) {
            // 获取同步队列的head结点
            Node h = head;
            if (h != null && h != tail) {
                // 获取head节点的等待状态
                int ws = h.waitStatus;
                // 如果head节点的状态为SIGNAL, 表明后面有人在排队
                if (ws == Node.SIGNAL) {
                    // 先把head节点的等待状态更新为0
                    if (!compareAndSetWaitStatus(h, Node.SIGNAL, 0)) {
                        continue;
                    }
                    // 再去唤醒后继结点
                    unparkSuccessor(h);
                 // 如果head节点的状态为0, 表明此时后面没人在排队, 就只是将head状态修改为PROPAGATE
                }else if (ws == 0 && !compareAndSetWaitStatus(h, 0, Node.PROPAGATE)) {
                    continue;
                }
            }
            // 只有保证期间head结点没被修改过才能跳出循环
            if (h == head) {
                break;
            }
        }
    }

获取同步状态（或者说锁）的线程执行完逻辑后就会调用releaseShared方法释放同步状态，首先调用tryReleaseShared方法尝试释放同步状态该方法的判断逻辑由自定义子类覆盖它去实现的。

如果释放成功就调用doReleaseShared方法去唤醒后继结点。后它会找到原先的座位(head结点)，看看座位上是否有节点留了小纸条(状态为SIGNAL)，如果有就去唤醒后继结点。

如果没有(状态为0)就代表队列没节点在排队，那么在离开之前它还要做最后一件事情，就是在自己座位上留下小纸条(状态设置为PROPAGATE)，告诉后面的节点锁的获取状态。

整个释放锁的过程和独占模式唯一的区别就是在这最后一步操作。因为共享式释放同步状态的操作可能会同时来自多个线程，为了保证同步状态线程安全释放，一般是通过循环和CAS保证的。

--------------------

**AQS系列文章：**

**[1、队列同步器AQS源码分析之概要分析][1_AQS]**

**[2、队列同步器AQS源码分析之独占模式][2_AQS]**

**[3、队列同步器AQS源码分析之共享模式][3_AQS]**

**[4、队列同步器AQS源码分析之Condition接口、等待队列][4_AQS_Condition]**

## 参考及推荐： ##

**[1、AbstractQueuedSynchronizer源码分析之概要分析][1_AbstractQueuedSynchronizer]**

**2、[AbstractQueuedSynchronizer源码分析之独占模式][AbstractQueuedSynchronizer]**

**3、[AbstractQueuedSynchronizer源码分析之共享模式][AbstractQueuedSynchronizer 1]**

**4、[AbstractQueuedSynchronizer源码分析之条件队列][AbstractQueuedSynchronizer 2]**

[1_AQS]: https://blog.csdn.net/pcwl1206/article/details/84972609
[2_AQS]: https://blog.csdn.net/pcwl1206/article/details/84980812
[3_AQS]: https://blog.csdn.net/pcwl1206/article/details/84983118
[4_AQS_Condition]: https://blog.csdn.net/pcwl1206/article/details/84984713
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Bjd2wxMjA2_size_16_color_FFFFFF_t_70]: /images/20220405/cdc1d064c8de481f942e3527e4090b24.png
[1_AbstractQueuedSynchronizer]: https://mp.weixin.qq.com/s/RzD-_SAo3f68lS_05H4B2g
[AbstractQueuedSynchronizer]: https://mp.weixin.qq.com/s/ORoB7yj5oA35FCtuR8gYUA
[AbstractQueuedSynchronizer 1]: https://mp.weixin.qq.com/s/BGB1_UTujwmlQAFIwx4zXQ
[AbstractQueuedSynchronizer 2]: https://mp.weixin.qq.com/s/95wZVLSGbY9ubu3Ot-eAvQ