为什么java.util.concurrent.ArrayBlockingQueue为什么在调用await（）时使用“ while”循环而不是“ if”循环？

Question

我一直在使用“
if”来测试自己的版本，并且一切似乎都正常。当然，如果使用signalAll（）而不是signal（），这将导致严重崩溃，但是如果一次仅通知一个线程，这怎么会出错？

他们的代码在这里
-检查put（）和take（）方法；在Condition的JavaDoc顶部可以看到一个更简单，更重点的实现。

下面是我实施的相关部分。

public Object get() {
    lock.lock();
    try {
        if( items.size() < 1 )
            hasItems.await();
        Object poppedValue = items.getLast();
        items.removeLast();
        hasSpace.signal();
        return poppedValue; 
    } catch (InterruptedException e) {
        e.printStackTrace();
        return null;
    } finally {
        lock.unlock();
    }
}

public void put(Object item) {
    lock.lock();
    try {
        if( items.size() >= capacity )
            hasSpace.await();
        items.addFirst(item);
        hasItems.signal();
        return;
    } catch (InterruptedException e) {
        e.printStackTrace();
    } finally {
        lock.unlock();
    }
}

PS我知道，通常，尤其是在这样的lib类中，应该让异常渗入。

Answer 1

防止虚假唤醒。JVM并不能保证线程将再次开始运行的唯一可能原因是因为您按预期的方式调用了signal。有时，它会只是偶然地开始而已（虚假唤醒）。因此，如果要运行的条件实际上不是真的，则必须再次等待。

这在javadoc中对wait方法进行了解释：http
:
//java.sun.com/javase/6/docs/api/java/lang/Object.html#wait%28long%29

并在文档中提及等待：http
:
//java.sun.com/javase/6/docs/api/java/util/concurrent/locks/Condition.html#await%28%29

与此条件相关联的锁被原子释放，并且出于线程调度的目的，当前线程被禁用，并且处于休眠状态，直到发生以下四种情况之一：

• 其他一些线程为此条件调用signal（）方法，并且当前线程恰好被选择为要唤醒的线程；要么

• 其他一些线程为此条件调用signalAll（）方法。要么

• 其他一些线程中断当前线程，并支持中断线程挂起；要么

*发生“虚假唤醒”。

Condition接口的某些实现可能会抑制虚假唤醒，但是依赖该实现将因此依赖于实现细节，并使您的代码不可移植。