Чтение Java-очереди из нескольких тем со всеми объектами в каждой теме.

Question

Существует ли стандартная или сторонняя реализация java.util.Queue, которая позволяет мне читать очередь одновременно в нескольких потоках, но доставляет все объекты во все потоки.

Цель состоит в том, чтобы выполнять множественную параллельную обработку сообщений, регулярно добавляемых в очередь.Некоторые процессы быстрые, а другие медленные.Нам нужно, чтобы все сообщения обрабатывались всеми потоками.

Answer 1

Эта задача решается в библиотеках, которые поддерживают инициативу Reactive Streams , например, Project Reactor или RxJava .Насколько я знаю, все они поддерживают только асинхронных производителей и потребителей, а не потоков.Но я верю, что легко создать адаптеры от асинхронного (неблокирующего) к синхронному (блокирующему) способу связи.И, вероятно, асинхронное решение лучше в вашем случае.