DelayQueue是Java中基于优先级队列实现的无界阻塞队列，用于存放实现Delayed接口的对象，只有当对象的延迟时间到达后才能被取出，适用于定时任务、缓存过期等场景。
在Java中，DelayQueue 是一个无界阻塞队列，它用于存放实现了 Delayed 接口的对象。只有当对象的延迟时间到达后，才能从队列中取出。这个特性非常适合实现定时任务、缓存过期、消息延迟处理等场景。
DelayQueue 的基本原理
DelayQueue 要求队列中的元素必须实现 java.util.concurrent.Delayed 接口。该接口有两个方法：
- getDelay(TimeUnit unit)：返回当前对象还需要延迟的时间。
- compareTo(Delayed other)：用于排序，决定谁先出队。
DelayQueue 内部基于优先级队列（PriorityQueue）实现，元素按延迟时间排序，延迟最短的排在队首。
实现自定义延迟任务
要使用 DelayQueue，需要创建一个类实现 Delayed 接口。以下是一个简单的示例：
立即学习“Java免费学习笔记（深入）”；
import java.util.concurrent.Delayed; import java.util.concurrent.TimeUnit;public class DelayTask implements Delayed { private String message; private long executeTime; // 执行时间戳（毫秒）
public DelayTask(String message, long delayInMilliseconds) { this.message = message; this.executeTime = System.currentTimeMillis() + delayInMilliseconds; } @Override public long getDelay(TimeUnit unit) { long diff = executeTime - System.currentTimeMillis(); return unit.convert(diff, TimeUnit.MILLISECONDS); } @Override public int compareTo(Delayed other) { return Long.compare(this.executeTime, ((DelayTask) other).executeTime); } public String getMessage() { return message; }}
使用 DelayQueue 处理延迟任务
下面演示如何向 DelayQueue 添加任务，并由消费者线程取出执行：
import java.util.concurrent.*;public class DelayQueueExample { public static void main(String[] args) { DelayQueue
queue = new DelayQueue<>(); // 添加几个延迟任务 queue.put(new DelayTask("任务1 - 5秒后执行", 5000)); queue.put(new DelayTask("任务2 - 3秒后执行", 3000)); queue.put(new DelayTask("任务3 - 8秒后执行", 8000)); System.out.println("任务已提交"); // 消费者线程处理任务 while (!queue.isEmpty()) { try { DelayTask task = queue.take(); // take() 会阻塞直到有任务到期 System.out.println("执行: " + task.getMessage()); } catch (InterruptedException e) { Thread.currentThread().interrupt(); break; } } }}
输出结果会按照延迟时间顺序打印，即使任务不是按顺序添加的。
注意事项和最佳实践
使用 DelayQueue 时需要注意几点：
- DelayQueue 是线程安全的，适合多线程环境。
- put() 操作不会阻塞，因为是无界队列，但要注意内存溢出风险。
- take() 和 poll() 方法会等待直到有任务到期，poll(long, TimeUnit) 可设置超时。
- 确保 compareTo 方法与 getDelay 的逻辑一致，避免排序错误。
- 如果系统时间被调整，可能影响延迟准确性，生产环境需注意时钟同步。
基本上就这些。DelayQueue 提供了一种简单而强大的方式来处理延迟任务，合理使用可以避免手动轮询或 Timer 的复杂性。不复杂但容易忽略的是 compareTo 的实现必须与延迟时间一致，否则可能导致任务无法正确触发。
