BlockingQueue在任何时候对所有线程都是一样的吗？

Question

我正在实现一个程序，主线程将各种消息推送到工作线程，工作线程将工作结果推送回主线程。

为此，我计划使用两个队列，一个推送到工作线程，另一个从中拉出。

据我所知，线程缓存对象，因此，如果它们要将对象添加到另一个线程可以轮询的队列中，则此更改可能不会立即可见，即它可能不会同步。这是正确的吗？

但是，如果我要使用BlockingQueue，则该队列上的所有操作都应该对所有线程立即可见？

Answer 1

BlockingQueue接口的javadoc是这样说的：

“BlockingQueue实现是线程安全的。所有排队方法都使用内部锁或其他形式的并发控制以原子方式实现其效果。”

因此，可以保证一个线程对队列所做的更改“立即”对其他线程可见。。。在记忆模型的意义上。同步put和poll调用已完成。（任何缓存效果都由javadoc中提到的机制来处理。）

当然，这并不意味着他们所有人都会看到语义级别的变化。这取决于线程调度等事情。（如果一个对象被添加到队列中，只有一个线程能够删除它。如果它在第二个线程看到队列状态之前这样做......无论出于什么原因......第二个线程不会注意到添加了一个条目，然后又删除了。）

“立即”的粒度也未指定。例如，如果JVM只使用一个CPU/内核，那么线程只能在发出put调用的线程取消调度后（无论出于何种原因）从轮询返回。此外，刷新内存缓存中的更改需要相当长的时间。

这假设实现类满足“契约”。。。但如果没有，那就是马车

Answer 2

根据你最初的问题和评论，你混淆了两件不同的事情。

任何实现BlockingQueue的东西都是线程安全的并且可以正确发布。实现该接口的类的内部各不相同，因此“该队列上的所有操作都应该对所有线程立即可见”的说法对于立即的某些定义可能不正确。“非常快”将是一个更恰当的描述；它可能没有使用阻塞/锁定机制，并且总是涉及线程调度。

安全发布（线程缓存）与Java中线程的工作方式有关，是一个更大的主题。必须安全地发布对该BlockingQueue的引用，以便所有线程都能看到它。在大多数情况下，当使用这样的结构时，您可能做了正确的事情。也就是说，要么将引用传递给可运行的构造函数，要么将其创建为某个地方的最终变量。但实际上，只要你没有得到NullPointerException。。。线程可以看到它。

当您将对象传递给多个线程后，在对象内部实例化某个对象时，就会出现安全发布问题。

关于这个主题的实际参考是Java并发，值得拥有。

Answer 3

这个答案假设您谈论的是线程安全的数据结构或构造。如果使用常规的非线程安全字段，则不能保证它会工作，但也不能保证它不会工作。注意：这是线程安全的单元测试有用，但不是傻瓜式的。

此更改可能不会立即可见，即可能不会同步。这是正确的吗？

对延迟通常为50-100纳秒，因此可能几乎是立即发生的。

此队列上的所有操作都应该对所有线程立即可见？

这在真正的机器中是不可能的。你可以说的是，你永远不会因为可视性问题而出错，主要是非常轻微的延迟。（但是，由于它会产生垃圾，因此在最坏的情况下，如果机器没有Hibernate，您可以获得完全的GC延迟，在这种情况下，延迟可能是数小时或数天）