关于 AQS 中的 acquire 方法的一点疑惑

V2EX = way to explore

V2EX 是一个关于分享和探索的地方

现在注册

已注册用户请登录

这是一个创建于 1107 天前的主题，其中的信息可能已经有所发展或是发生改变。

public final void acquire(int arg) {

    if (!tryAcquire(arg) &&

        acquireQueued(addWaiter(Node.EXCLUSIVE), arg))

        selfInterrupt();

}

这是 AQS 中的模板 acquire 方法，里面有个 acquireQueued 方法：

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

代码逻辑会判断当前节点的前驱结点是不是头结点（ p == head ），如果是才去获取锁。我看了下 ReentrantLock 中的非公平锁也会走到这一段逻辑来，那这还叫非公平锁吗？为什么非公平锁也要去 CLH 队列判断当前线程结点是不是头结点？

4 条回复