java - Java中多生产者单消费者的软件设计

Question

我有多个生产者，每个生产者都将数据推送到自己的阻塞队列中。每个生产者的数据都是独立处理的（因此有单独的队列）。

我的单个消费者目前轮询每个队列，每个队列都有超时。

程序运行良好，但我正在尝试优化，我不喜欢“轮询”。这是解决此问题的最有效方法吗？

我使用每个生产者的消费者编写了相同的应用程序，但情况稍差。

谢谢 。

Answer 1

尝试将消费者注册为队列上的侦听器，以便队列状态的变化通知消费者而无需主动轮询（控制反转）。