是否有 java.util.Queue 的标准或第三方实现,它允许我在多个线程中同时读取队列,但将所有对象传递给所有线程。
目标是对定期添加到队列中的消息进行多个并行处理。有些进程很快,而另一些进程则很慢。我们需要所有消息都由所有线程处理。
最佳答案
此任务在支持 Reactive Streams 的库中得到解决倡议,例如 Project Reactor或RxJava 。据我所知,它们仅支持异步生产者和消费者,而不支持线程。但我相信创建从异步(非阻塞)到同步(阻塞)通信方式的适配器很容易。对于您的情况,异步解决方案可能更好。
关于java - 从多个线程中读取java "Queue",每个线程中包含所有对象,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/54440514/