DelayQueue是Java中基于延迟时间排序的无界阻塞队列，用于实现延迟任务调度。1. Delayed接口需实现getDelay()和compareTo()方法，确保任务按延迟时间有序取出。2. 自定义DelayTask类实现Delayed接口，封装任务ID和执行时间戳。3. 使用DelayQueue存储任务，通过单独消费者线程调用take()获取到期任务并执行。4. 注意线程安全、单消费者模式、延迟精度、异常处理及优雅关闭。适用于轻量级场景，如缓存清理、延时消息，无需引入复杂调度框架。
在Java中，DelayQueue 是一个无界阻塞队列，用于存放实现了 Delayed 接口的对象。只有当对象的延迟时间到期后，才能从队列中获取到它。这个特性非常适合实现延迟任务调度，比如定时清理缓存、延时发送消息等场景。
1. DelayQueue 和 Delayed 接口的基本原理
Delayed 接口要求实现两个方法：
- getDelay(TimeUnit unit)：返回当前对象还需要等待多长时间才能被消费，单位由参数指定。
- compareTo(Delayed other)：用于排序，DelayQueue 内部基于优先级队列（堆）实现，会根据延迟时间排序。
只有当 getDelay() 返回值小于等于0时，元素才会被取出。
2. 定义延迟任务
创建一个类实现 Delayed 接口，表示具体的延迟任务。例如：
立即学习“Java免费学习笔记（深入）”；
import java.util.concurrent.Delayed; import java.util.concurrent.TimeUnit;public class DelayTask implements Delayed { private String taskId; private long executeTime; // 执行时间戳（毫秒）
public DelayTask(String taskId, long delayInMs) { this.taskId = taskId; 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 other) { return Long.compare(this.executeTime, ((DelayTask) other).executeTime); } public String getTaskId() { return taskId; }}
3. 使用 DelayQueue 调度任务
启动一个消费者线程，不断从队列中获取到期的任务并执行：
import java.util.concurrent.*;public class DelayTaskScheduler { private final DelayQueue
queue = new DelayQueue<>(); public void addTask(DelayTask task) { queue.put(task); } public void start() { new Thread(() -> { try { while (!Thread.interrupted()) { DelayTask task = queue.take(); // 阻塞直到任务到期 System.out.println("执行任务: " + task.getTaskId()); } } catch (InterruptedException e) { Thread.currentThread().interrupt(); } }).start(); } public static void main(String[] args) { DelayTaskScheduler scheduler = new DelayTaskScheduler(); scheduler.start(); // 添加几个延迟任务 scheduler.addTask(new DelayTask("任务1", 2000)); scheduler.addTask(new DelayTask("任务2", 5000)); scheduler.addTask(new DelayTask("任务3", 3000)); System.out.println("所有任务已提交"); }}
输出结果会是：
所有任务已提交 执行任务: 任务1 执行任务: 任务3 执行任务: 任务24. 注意事项和优化建议
- 线程安全：DelayQueue 本身是线程安全的，多个线程可以并发添加任务。
- 单消费者模式：通常使用一个单独的线程处理 take()，避免多个线程重复执行同一任务。
- 精度限制：DelayQueue 不是高精度定时器，适合秒级或几百毫秒以上的延迟任务。
- 任务异常处理：在消费任务时应加上 try-catch，防止某个任务出错导致整个调度线程中断。
- 关闭机制：可通过中断线程或添加“停止哨兵任务”来优雅关闭调度器。
基本上就这些。DelayQueue 简单高效，适用于轻量级延迟任务场景，不需要引入 Quartz 或 ScheduledExecutorService 的复杂性。
