Скажем, у меня есть очередь задержки следующим образом:
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
