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



我有多个生产者,每个生产者将数据推送到自己的阻塞队列中。来自每个生产者的数据是独立处理的(因此是单独的队列)。

我的单个使用者当前轮询每个队列,每个队列都有超时。

程序工作正常,但我正在尝试优化,我不喜欢"轮询"。这是解决这个问题的最有效方法吗??

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

谢谢。

尝试将使用者注册为队列上的侦听器,以便队列状态的更改在不主动轮询的情况下通知使用者(控制反转)。

最新更新