DelayQueue是Java中的一個無界阻塞隊列,實現了Delayed接口,其中的元素可以在指定的延遲時間之后被取出。下面是使用DelayQueue的步驟:
創建DelayQueue對象:
DelayQueue<DelayedElement> delayQueue = new DelayQueue<>();
創建實現Delayed接口的元素類DelayedElement:
public class DelayedElement implements Delayed {
private long delayTime; // 延遲時間
private long expireTime; // 到期時間
private String data; // 數據
// 構造函數
public DelayedElement(long delayTime, String data) {
this.delayTime = delayTime;
this.expireTime = System.currentTimeMillis() + delayTime;
this.data = data;
}
// 獲取剩余延遲時間
@Override
public long getDelay(TimeUnit unit) {
return unit.convert(expireTime - System.currentTimeMillis(), TimeUnit.MILLISECONDS);
}
// 隊列元素的排序規則
@Override
public int compareTo(Delayed o) {
if (this.expireTime < ((DelayedElement) o).expireTime) {
return -1;
} else if (this.expireTime > ((DelayedElement) o).expireTime) {
return 1;
} else {
return 0;
}
}
// 元素是否到期
public boolean isExpired() {
return System.currentTimeMillis() >= expireTime;
}
// 獲取數據
public String getData() {
return data;
}
}
向DelayQueue中添加元素:
delayQueue.offer(new DelayedElement(1000, "Element 1")); // 延遲1秒
delayQueue.offer(new DelayedElement(2000, "Element 2")); // 延遲2秒
...
從DelayQueue中取出已到期的元素:
DelayedElement delayedElement = delayQueue.take();
String data = delayedElement.getData();
需要注意的是,take()方法是一個阻塞方法,如果隊列中沒有元素到期,它會一直阻塞直到有元素到期為止。如果想要非阻塞地獲取已到期的元素,可以使用poll()方法。
另外,可以通過重寫DelayedElement類的compareTo()方法來指定元素的排序規則,從而決定哪些元素先被取出。在上述例子中,元素的排序規則是按照到期時間的先后順序進行排序。