Java中的阻塞队列

Question

我正在阅读一本名为“Beginning Algorithms”的书，其中包含 Java 示例。在关于队列的章节中，它解释了“阻塞队列”，并且......即使我的背景是 C# 而不是 Java，我觉得有些东西很有趣。

这是代码的一部分（我省略了不相关的部分）：

public void enqueue(Object value){
    synchronized(_mutex){
        while(size == _max_size){
            waitForNotification();
        }
        _queue.enqueue(value);
        _mutex.notifyAll();
    }
}

private void waitForNotification(){
    try {
        _mutex.wait();
    } catch( InterruptedException e){
        // Ignore
    }
}

public Object dequeue() throws EmptyQueueException {
    synchronized(_mutex){
        while(isEmpty()){
            waitForNotification();
        }
        Object value = _queue.dequeue();
        _mutex.notifyAll();
        return value;
    }
}

我看到了两个主要问题。

首先，如果队列满了，有5个线程在等待添加item，其他线程dequeue 1 item，另外5个会被释放，同时会检查“size() == _max_size”是否不再为真，他们将尝试调用“_queue.enqueue”5 次，导致队列溢出。

其次，同样的情况也发生在“dequeue”中。如果由于队列为空而阻止多个线程尝试使项目出队，添加一个将导致所有线程检查队列不再为空，并且所有线程都将尝试出队，得到 null 或我猜的异常。

我说的对吗？我的 C# 有一个“Monitor.Pulse”，它只释放一个被阻塞的线程，这会是解决方案吗？

干杯。

Answer 1

您忽略了synchronized 声明。这只允许一个线程获取_mutex。因此，只有一个线程能够检查size 的值，因为while 语句位于synchronized 块内。

如this thread 中所述，wait() 方法实际上释放了_mutex 对象并等待对notify() 的调用，或者在这种情况下为notifyAll()。此外，notifyAll() 只会将_mutex 上的锁授予一个等待线程。