java生产者消费者模式结束信号

Question

我有一个应用生产者-消费者设计模式的应用程序。它是用java编写的。简而言之，生产者将项目放在阻塞队列中，消费者从那里取出项目。消费者应该一直运行，直到生产者发出停止的信号。

将这个信号从生产者传递给消费者的最好的方式是什么？首席设计师说他希望保持生产者和消费者的分离，但除了在消费者线程池上调用一个方法之外，我没有看到其他任何方法。

Answer 1

首席程序员是对的。保持它们的分离会导致高度解耦的代码，这是非常好的。

有几种方法可以做到这一点。其中一种叫“毒丸”。这就是它的工作原理--当消费者看到一个已知的项目时，他们会自杀或者采取另一个行动。

如果有多个消费者(您提到的是ThreadPool)或有界队列，这可能会很棘手。请在Joshua Bloch的Java Concurrency in Practice中查找这一点。他解释得最好。

Answer 2

通过队列发送取消消息。您的消费者的run方法将如下所示

while(true) {
    Message message = queue.take();
    if(message == Message.Cancel) {
        queue.offer(message); // so that the other consumers can read the Cancel message
        break;
    }
}

Answer 3

创建一个ConsumerHalter类。将希望从queue获取数据的所有使用者注册到ConsumerHalter类，并让生产者在ConsumerHalther类中触发halt事件。然后，ConsumerHalter类调用每个使用者的onStopConsuming()。