Java教程

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

本文主要是介绍java基础----AQS---acquireQueued详解,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!
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;
}
这篇关于java基础----AQS---acquireQueued详解的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!