Поток из очереди задержки в Java ⇐ JAVA

[Anonymous]

Скажем, у меня есть очередь задержки следующим образом:
DelayQueue queue= new DelayQueue();

Я хотел бы получить следующее поведение:
while (true) {
DealyedObject next = queue.take();
System.out.println("next message:" + next);
}

но со следующими потоками:
queue.stream().forEach(e -> System.out.println(e));

Однако я заметил, что это не учитывает задержку, а также похоже, что оно подглядывает и не принимает. Это ожидаемое поведение? Есть ли лучший способ добиться того, что мне нужно, с помощью потоков?
Вот полностью воспроизводимый образец:


import java.util.UUID;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.DelayQueue;
import java.util.concurrent.Delayed;
import java.util.concurrent.TimeUnit;

public class DelayQueueExample {
public class DelayObject implements Delayed {
private String data;
private long startTime;

public DelayObject(String data, long delayInMilliseconds) {
this.data = data;
this.startTime = System.currentTimeMillis() + delayInMilliseconds;
}

@Override
public long getDelay(TimeUnit unit) {
long diff = this.startTime - System.currentTimeMillis();
return unit.convert(diff, TimeUnit.MILLISECONDS);
}

@Override
public int compareTo(Delayed o) {
return Math.toIntExact(this.startTime - ((DelayObject) o).startTime);
}

public String toString(){
return this.data;
}
}

public void startLoop() throws InterruptedException {
BlockingQueue delayQueue= new DelayQueue();
DelayObject object1 = new DelayObject("Object1ExpiresIn1MS",1);
DelayObject object2 = new DelayObject("Object1ExpiresIn10000MS",10000);
delayQueue.add(object1);
delayQueue.add(object2);

while(!delayQueue.isEmpty()){
System.out.println(delayQueue.take());
}

}

public void startStream() throws InterruptedException {
BlockingQueue delayQueue= new DelayQueue();
DelayObject object1 = new DelayObject("Object1ExpiresIn1MS",1);
DelayObject object2 = new DelayObject("Object1ExpiresIn10000MS",10000);
delayQueue.add(object1);
delayQueue.add(object2);

delayQueue.forEach(o->System.out.println(o));

}

public static void main(String[] args) throws InterruptedException {
DelayQueueExample ex1 = new DelayQueueExample();
ex1.startLoop(); //Immediately outputs Object1ExpiresIn1ms and Object1ExpiresIn10000MS after 10ms
ex1.startStream(); //Immediately outputs Object1ExpiresIn1ms,Object1ExpiresIn10000MS
}
}



Подробнее здесь: https://stackoverflow.com/questions/708 ... ue-in-java