lock（）方法在ReentrantLock java中的工作原理

Question

我试图理解ReentrantLock在java中是如何工作的。

让我们考虑下面的一个简单示例：

private ReentrantLock lock;
public void foo() {
    lock.lock();
    try{
        ...
    }finally {
        lock.unlock();
    }
}

我试图弄清楚lock（）方法的调用层次结构。

public void lock() {
    sync.lock();
}

对于FairSync：

final void lock() {
    acquire(1);
}

对于非空中同步：

final void lock() {
    if (compareAndSetState(0, 1))
        setExclusiveOwnerThread(Thread.currentThread());
    else
        acquire(1);
}

这两个lock（）方法都调用参数为1的acquire（）方法。

在AbstractQueuedSynsynizer类中：

public final void acquire(int arg) {
    if (!tryAcquire(arg) &&
        acquireQueued(addWaiter(Node.EXCLUSIVE), arg))
        selfInterrupt();
}

static void selfInterrupt() {
    Thread.currentThread().interrupt();
}

如果当前线程无法获取资源（即，另一个线程已经获取了该资源），那么当前线程必须等待。在本例中，ReentrantLock调用selfInterrupt（）方法。

现在我的问题是interrupt（）方法如何停止一个线程，这个线程相当于synchronized中的wait（）方法？

另外，在资源被另一个线程释放后，currentThread如何自动启动？（在另一个线程调用unlock（）方法之后，该线程正在内部调用sync。释放（1） ）

我还试图从这里找出interrupt（）方法是如何工作的，但找不到问题的答案。




Answer 1

如果当前线程无法获取资源（即，另一个线程已经获取了该资源），那么当前线程必须等待。在这种情况下，ReentrantLock调用selfInterrupt（）方法。

否，如果tryAcquire返回false，将调用acquiredqueued。在内部，该方法使用LockSupport#park来取消线程调度。javadoc声明

如果许可证可用，则该许可证被消耗，呼叫立即返回；否则，出于线程调度目的，当前线程将被禁用，并处于Hibernate状态，直到发生以下三种情况之一：
-[…]
-其他线程会中断当前线程；

实际上，它不会抛出一个InterruptedException，在这种情况下，该方法只会返回。要检查对应的线程是否因中断而被唤醒，它必须使用thread#interrupted（），根据具体情况返回true或false，同时清除相应线程实例上的中断标志。

因此，获取队列传播该中断值备份，并让获取重置线程上的中断标志，如果需要在那一小段代码中

if (!tryAcquire(arg) &&
    acquireQueued(addWaiter(Node.EXCLUSIVE), arg))
    selfInterrupt();

另外，在资源被另一个线程释放后，当前线程如何自动启动？

同样，它使用带有unpark的LockSupport实用程序

使给定线程的许可证可用（如果尚未可用）。如果线程在park上被阻塞，那么它将解除阻塞。