java - 我们需要 ArrayBlockingQueue.put(E) 中的 Condition.signal

Question

我正在查看ArrayBlockingQueue.put(E)的代码。我们真的需要在 catch block 中调用 notFull.signal 吗？该信号不应该由消费者调用吗？

public void put(E e) throws InterruptedException {
    if (e == null) throw new NullPointerException();
    final E[] items = this.items;
    final ReentrantLock lock = this.lock;
    lock.lockInterruptibly();
    try {
        try {
            while (count == items.length)
                notFull.await();
        } catch (InterruptedException ie) {
            notFull.signal(); // propagate to non-interrupted thread
            throw ie;
        }
        insert(e);
    } finally {
        lock.unlock();
    }
}

Answer 1

问题似乎是，如果发出了一个条件信号，并且线程被中断，则 await() 会消耗该信号并抛出 InterruptedException。但是，javadoc 特别禁止 - 如果 await() 抛出 InterruptedException，则它不得消耗信号。

类似的问题也适用于Object.wait()。在 1.4 中，javadoc 不是很明确。从 1.5 开始，javadoc 说

Throws: InterruptedException - if another thread interrupted the current thread before or while the current thread was waiting for a notification.

这似乎暗示如果 wait() 抛出 InterruptedException，它一定不能使用通知。