【发布时间】：2018-12-13 13:09:46
【问题描述】：
我在编写 Java 方面还是个新手，我目前正在尝试实现经典“生产者-消费者”问题的不同方面。我仍然像往常一样使用一个生产者，他在缓冲区中写入字符串。这个缓冲区与 2 个消费者线程共享，我想做的是让两个消费者都拿起生产者发送的每个字符串，然后才从缓冲区中删除字符串。我如何检查两个消费者线程是否已经获取了字符串？？？谢谢！
【问题讨论】：
-
让我们看看kafka主题或rabbitmq fanout交换是如何工作的。您可以在内存中实现它们的非常基本的版本。
-
我认为这将不再是生产者-消费者。这比仅仅填充两个队列要复杂得多，每个队列对应这些不同的消费者。
标签： java buffer consumer producer