阻塞队列元素对其他线程不可见有时会导致没有元素检索

Question

我正在使用LinkedBlokingQueue，它在 2 个线程之间共享。从第一个线程构造函数我已将Queue 对象传递给第二个线程。

我在第一个线程中使用likedBlockingQueue.put。

第二个线程使用likedBlockingQueue.size()>0 和likedBlockingQueue.peek() 获取元素。

问题出在我的环境中，有时第二个线程为空，尽管我可以看到第一个线程在 put 处处于阻塞调用（因为我已将队列大小初始化为 1）。这个问题并不总是发生，但有时只会复制。根据 java 文档，无法理解导致此问题的原因，此队列似乎是线程安全的。有人可以就此分享任何观点吗？

我尝试复制这个，但只发生了几次，其他时候我可以从队列中获取元素。

1 个主题：

private final Queue<T> linkedQ = new LinkedBlokingQueue(1);
linkedQ.put(element);

2 线程：

while(condition)
{
    if(this.linkedQ.size>0)
    {
        Object a = this.linkedQ.peek();
        linkedQ.remove();
        break;
    }
}

没有错误，出现这个问题的时候调试，第二个线程中的Q显示为空。

Answer 1

在这种情况下，您不应使用size()、peek() 或remove()。 LinkedBlockingQueue 是一个阻塞队列（因此​​得名）。 size() 和 peek() 都是非阻塞的（好吧，从技术上讲，它们会阻塞一秒钟，但它们不会以生产者-消费者的方式行事）。

您需要一个告诉当前线程“在此等待，直到元素出现在队列中”的操作。查看 API，peek() 显示为

检索但不删除此队列的头部，如果此队列为空，则返回 null。

如果队列为空，则返回 null 说明不执行等待。您要查找的操作是take()。

public E take()

检索并移除此队列的头部，如有必要，等待元素可用。

你在这里的用法是：

while(condition) {
    Object a = linkedQ.take(); // leaving out the interrupted exception for brevities sake
}