java基础----AQS---acquireQueued详解

2022-07-21 15:00:48 阅读：176 来源： 互联网


1. 假设有A、B、C三个线程同时执行，A线程获取到了锁，并且一直持有中。
2. B线程执行，获取锁失败会被加到等待队列中，因为此时队列为空，则建立空节点head，同时B线程添加节点到队列中，作为第一个等待的节点，所以此时队列中有两个节点，头节点和B节点，他们的等待状态都是0。
3. B在acquireQueued方法中，for循环尝试获取锁，他的前驱是头节点，但是获取锁失败，此时运行到shouldParkAfterFailedAcquire，在这个方法中，判断B线程的前驱节点（就是头节点）的等待状态，发现是0，
那么会把它设置为-1（标示SIGNAL）；返回false以后，再次尝试去获取锁，再次失败以后再次进入到shouldParkAfterFailedAcquire，此时前驱节点状态是-1，那么就会park线程B。
4. C也同样在acquireQueued获取锁失败后被加到B节点后面，执行shouldParkAfterFailedAcquire，B节点的状态是0，那么C也会在把B状态设置为-1以后返回false继续尝试获取锁，失败以后在进入shouldParkAfterFailedAcquire
，此时前驱B节点状态是-1，那么C也会被挂起。
5. 如果后面还有线程D、E、F都会这样。
6. 直到A释放锁以后，他会唤醒等待队列中head以后第一个节点，就是B节点，B节点醒来继续for循环当中的获取锁，因为此时A已经释放锁，那么B可以获取锁成功，他会把自己设置为头节点。线程设为空，前驱设为空。
7. B执行完以后也会释放锁，唤醒他后面的节点，就是C，C再获取锁继续执行。
8. D、E、F也都如此。



final boolean acquireQueued(final Node node, int arg) {
    boolean failed = true;
    try {
        boolean interrupted = false;
        for (;;) {
            final Node p = node.predecessor();
            if (p == head && tryAcquire(arg)) {
                setHead(node);
                p.next = null; // help GC
                failed = false;
                return interrupted;
            }
            if (shouldParkAfterFailedAcquire(p, node) &&
                parkAndCheckInterrupt())
                interrupted = true;
        }
    } finally {
        if (failed)
            cancelAcquire(node);
    }
}



此方法是在获取锁失败以后判断是否需要park的方法，非常重要，所有的获取锁的方法都需要调用的：

private static boolean shouldParkAfterFailedAcquire(Node pred, Node node) {
    int ws = pred.waitStatus;
    if (ws == Node.SIGNAL) //前驱节点状态判断是SIGNAL，那么说明本节点需要被唤醒，返回true,这里返回true以后就能运行后面的parkAndCheckInterrupt方法。


        /*
         * This node has already set status asking a release
         * to signal it, so it can safely park.
         */
        return true;
    if (ws > 0) {//说明前驱节点是取消状态，则往前遍历，直到找到前驱几点状态是非取消的节点为止。返回false,不park，继续尝试获取锁。如果获取失败再次进入到次方法中，如果是signal那么就执行上面逻辑，如果是其他小于等于0执行下面的逻辑
        /*
         * Predecessor was cancelled. Skip over predecessors and
         * indicate retry.
         */
        do {
            node.prev = pred = pred.prev;
        } while (pred.waitStatus > 0);
        pred.next = node;
    } else {//说名前驱状态是0或者是传播模式。那么设置前驱节点状态是signal，返回false，不park。继续尝试获取锁。
        /*
         * 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);
    }
    return false;
}

标签：node,java,AQS,pred,---,获取,前驱,线程,节点
来源： https://www.cnblogs.com/ygliu/p/15675850.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

java基础----AQS---acquireQueued详解