Предположим, у нас есть очередь
BlockingQueue queue= new LinkedBlockingQueue();
и какой-то другой поток помещает в него значения, затем мы читаем его как
while (true) {
String next = queue.take();
System.out.println("next message:" + next);
}
Как я могу перебирать эту очередь в потоковом стиле, сохраняя при этом семантику, аналогичную приведенному выше коду.
Это код проходит только текущее состояние очереди:
queue.stream().forEach(e -> System.out.println(e));
Подробнее здесь: https://stackoverflow.com/questions/234 ... ream-style
