У меня есть поток, который обрабатывает входящие сообщения (бесконечный цикл). Для этого я использую BlockingQueue (Java), который работает очень хорошо. Теперь я хочу добавить второй процессор в тот же метод Class oder. Проблема в том, что в бесконечном цикле у меня есть эта часть
newIncomming = this.incommingProcessing.take();
Эта часть блокируется, если очередь пуста. Я ищу решение для обработки очередей в том же классе. Вторая очередь может только обрабатываться, если некоторые данные поступают для первой очереди. Есть ли способ обрабатывать очереди блокировки буксировки в одном и том же бесконечном цикле?