Java延遲隊列(DelayQueue)是一個實現了Delayed接口的無界阻塞隊列,其中的元素只能在其到期時才能被取出。
延遲隊列可以用于定時任務調度,可以將需要延遲執行的任務添加到延遲隊列中,然后由消費者線程從隊列中取出延遲時間到期的任務進行執行。
以下是Java延遲隊列的應用示例:
public class DelayedTask implements Delayed {
private String taskName;
private long delayTime;
public DelayedTask(String taskName, long delayTime) {
this.taskName = taskName;
this.delayTime = System.currentTimeMillis() + delayTime;
}
@Override
public long getDelay(TimeUnit unit) {
return unit.convert(delayTime - System.currentTimeMillis(), TimeUnit.MILLISECONDS);
}
@Override
public int compareTo(Delayed o) {
return Long.compare(this.delayTime, ((DelayedTask) o).delayTime);
}
public void executeTask() {
// 執行任務邏輯
System.out.println("Task " + taskName + " executed!");
}
}
DelayQueue<DelayedTask> delayQueue = new DelayQueue<>();
// 添加延遲任務
delayQueue.offer(new DelayedTask("Task1", 3000));
delayQueue.offer(new DelayedTask("Task2", 5000));
delayQueue.offer(new DelayedTask("Task3", 1000));
Thread consumerThread = new Thread(() -> {
while (!Thread.currentThread().isInterrupted()) {
try {
DelayedTask task = delayQueue.take();
task.executeTask();
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
}
});
consumerThread.start();
延遲隊列會按照任務的延遲時間進行排序,到期時間越早的任務會排在隊列的前面,消費者線程從隊列中取出到期的任務進行執行。
以上就是Java延遲隊列的應用示例,可以根據實際需求靈活運用延遲隊列來實現定時任務調度等功能。