Java中的延遲隊列可以通過使用DelayQueue
類來實現。DelayQueue
是一個無界阻塞隊列,其中的元素按照指定的延遲時間進行排序。只有延遲期滿的元素才能從隊列中取出。
要實現延遲隊列,首先需要定義一個實現了Delayed
接口的類,該接口要求實現兩個方法:getDelay()
和compareTo()
。
import java.util.concurrent.Delayed;
import java.util.concurrent.TimeUnit;
public class DelayedElement implements Delayed {
private String data;
private long expireTime;
public DelayedElement(String data, long delayTime) {
this.data = data;
this.expireTime = System.currentTimeMillis() + delayTime;
}
@Override
public long getDelay(TimeUnit unit) {
long diff = expireTime - System.currentTimeMillis();
return unit.convert(diff, TimeUnit.MILLISECONDS);
}
@Override
public int compareTo(Delayed other) {
long diff = this.getDelay(TimeUnit.MILLISECONDS) - other.getDelay(TimeUnit.MILLISECONDS);
return diff > 0 ? 1 : (diff < 0 ? -1 : 0);
}
public String getData() {
return data;
}
}
import java.util.concurrent.DelayQueue;
public class Main {
public static void main(String[] args) throws InterruptedException {
DelayQueue<DelayedElement> delayQueue = new DelayQueue<>();
// 添加延遲元素
delayQueue.offer(new DelayedElement("Element 1", 2000));
delayQueue.offer(new DelayedElement("Element 2", 5000));
delayQueue.offer(new DelayedElement("Element 3", 3000));
// 遍歷獲取延遲元素
while (!delayQueue.isEmpty()) {
DelayedElement element = delayQueue.take();
System.out.println(element.getData());
}
}
}
以上代碼創建了一個DelayQueue
對象,并向隊列中添加了3個延遲元素,分別設置了不同的延遲時間。然后通過take()
方法從隊列中取出元素,并打印其數據。
注意:take()
方法是一個阻塞方法,如果隊列中沒有元素會一直等待,直到有元素被添加進來。如果想要非阻塞地獲取元素,可以使用poll()
方法。
這樣就實現了一個簡單的延遲隊列。