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

这篇文章介绍了java基础----AQS---acquireQueued详解，分享给大家做个参考，收藏Java资料网收获更多编程知识

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;
}

文章来源:https://www.cnblogs.com/ygliu/p/15675850.html
本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若内容造成侵权/违法违规/事实不符，请联系邮箱：jacktools123@163.com进行投诉反馈，一经查实，立即删除！