java - 从多个线程中读取java "Queue",每个线程中包含所有对象

标签 java multithreading queue

是否有 java.util.Queue 的标准或第三方实现,它允许我在多个线程中同时读取队列,但将所有对象传递给所有线程。

目标是对定期添加到队列中的消息进行多个并行处理。有些进程很快,而另一些进程则很慢。我们需要所有消息都由所有线程处理。

最佳答案

此任务在支持 Reactive Streams 的库中得到解决倡议,例如 Project ReactorRxJava 。据我所知,它们仅支持异步生产者和消费者,而不支持线程。但我相信创建从异步(非阻塞)到同步(阻塞)通信方式的适配器很容易。对于您的情况,异步解决方案可能更好。

关于java - 从多个线程中读取java "Queue",每个线程中包含所有对象,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/54440514/

相关文章:

java - 将页码放入文档中

java - Hibernate标准加载对象,对象会变得持久化吗?

iphone - 带有 UIActivityIndi​​cator 的 UIAlertView 显示得太晚/线程问题

c# - NET 3.5 中 Monitor.TryEnter 的替代方案

带队列的 Laravel 监听器不执行

c# - 使用 ffmpeg 和 C# 创建转换队列

java - 理解算法 - 多项式朴素贝叶斯

java - Android应用-无法启动 Activity ComponentInfo

java - 一个线程不停止其他线程。即使有 volatile 变量

node.js - 如何使用 Bull 和 Node.js 通过后台作业处理函数?