java - 线程之间的通信被阻止

Question

正如我的标题所说，我必须实现一个程序，其中线程通过发送消息(可序列化对象)相互通信。事实上，我希望线程在没有等待消息的情况下被阻塞。我已经在 Google 上查过，找到了 2 个解决方案:第一个解决方案使用 ObjectStream 和 PipedStream，第二个解决方案使用 BlockingQueue。我的问题是，这两种解决方案似乎不是最好的一种，因为 PipedStream 有很多错误(我在进行测试时有很多错误)，并且 BlockingQueue 在队列为空时不会阻塞线程。

大家有办法解决我的问题吗？

提前致谢;)

Answer 1

这基本上是一个生产者/消费者，其中线程可以是生产者和消费者中的一个或两者。我相信 BlockingQueue 可以为您提供所需的解决方案 ( http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/BlockingQueue.html )。特别是看看 put() 和 take() 方法。