Java DelayQueue如何实现延迟队列
DelayQueue是Java中用于延迟执行任务的无界阻塞队列，基于优先级队列实现，元素需实现Delayed接口，重写getDelay和compareTo方法以保证延迟时间和排序逻辑一致，适用于定时任务、缓存过期等场景。
DelayQueue 是 Java 并发包 java.util.concurrent 中的一个无界阻塞队列，用于实现延迟执行任务的场景。它内部基于优先级队列（PriorityQueue）实现，能够确保只有当元素的延迟时间到达后，才能从队列中取出。这个特性非常适合用在定时任务、缓存过期、任务调度等场景。
DelayQueue 的核心机制
要使用 DelayQueue，队列中的元素必须实现 Delayed 接口，该接口继承自 Comparable，要求实现两个方法：
- getDelay(TimeUnit unit)：返回当前元素还需要延迟的时间。
- compareTo(Delayed o)：用于排序，决定元素在队列中的优先级。
DelayQueue 内部通过一个优先级队列维护元素顺序，延迟时间最短的排在队首。但由于它是阻塞队列，即使元素已经到期，如果线程调用 take()，也会等待直到有元素可用。
如何定义延迟元素
通常我们会创建一个类，表示带延迟的任务或消息。例如：
class DelayedTask implements Delayed {
private String message;
private long executeTime; // 执行时间戳（毫秒）
public DelayedTask(String message, long delayInMs) {
this.message = message;
this.executeTime = System.currentTimeMillis() + delayInMs;
}
@Override
public long getDelay(TimeUnit unit) {
long diff = executeTime - System.currentTimeMillis();
return unit.convert(diff, TimeUnit.MILLISECONDS);
}
@Override
public int compareTo(Delayed o) {
return Long.compare(this.executeTime, ((DelayedTask) o).executeTime);
}
public String getMessage() {
return message;
}}
这个类记录了一个消息和它的执行时间。getDelay 返回剩余延迟时间，compareTo 确保延迟短的排前面。
使用 DelayQueue 实现延迟消费
下面是一个简单的使用示例：
public class DelayQueueExample {
public static void main(String[] args) throws InterruptedException {
DelayQueue queue = new DelayQueue<>();
// 添加几个延迟任务
queue.put(new DelayedTask("任务1", 3000));
queue.put(new DelayedTask("任务2", 5
000));
queue.put(new DelayedTask("任务3", 1000));
// 消费任务（会按延迟到期顺序取出）
while (!queue.isEmpty()) {
DelayedTask task = queue.take(); // 阻塞等待直到有任务到期
System.out.println("执行: " + task.getMessage() + "，时间：" + System.currentTimeMillis());
}
}}
000));
queue.put(new DelayedTask("任务3", 1000));
// 消费任务（会按延迟到期顺序取出）
while (!queue.isEmpty()) {
DelayedTask task = queue.take(); // 阻塞等待直到有任务到期
System.out.println("执行: " + task.getMessage() + "，时间：" + System.currentTimeMillis());
}
}输出结果会显示任务按实际延迟结束顺序打印，比如“任务3”最先执行，尽管最后加入。
关键特性与注意事项
- DelayQueue 是线程安全的，适合多线程环境。
- 不能放入 null 元素。
- take() 方法会一直阻塞，直到有元素到期；poll() 可以非阻塞获取，但可能返回 null。
- 元素必须正确实现 compareTo，否则队列排序可能出错。
- 因为是无界队列，大量未到期任务堆积可能导致内存问题。
基本上就这些。DelayQueue 提供了一种简洁高效的延迟处理方式，只要元素实现了 Delayed 接口，就能自动按时间顺序被消费。不复杂但容易忽略的是 getDelay 和 compareTo 的逻辑一致性。
