DelayQueue 实现延时任务调度的核心是线程安全的无界阻塞队列，仅存实现 Delayed 接口的任务，需配合消费者线程拉取到期任务；任务须正确实现 getDelay 和 compareTo，推荐用守护线程调用 take() 拉取并交由线程池并发执行，注意排序稳定性、时间跳变及内存泄漏风险。
Java 中用 DelayQueue 实现延时任务并发调度，核心在于：它本身是线程安全的无界阻塞队列，只存放实现了 Delayed 接口的任务，且仅当任务的延迟到期后才能被取出。它不主动触发执行，需配合一个或多个消费者线程（如单线程轮询或线程池）来拉取并处理到期任务。
任务对象必须实现 Delayed 接口
这是使用 DelayQueue 的前提。你需要定义一个任务类，实现 getDelay(TimeUnit)（返回剩余延迟时间）和 compareTo(Delayed)（用于队列内部排序，通常按到期时间升序）。
- 注意
getDelay必须返回「剩余」延迟，不是绝对时间戳；若为负值，表示已到期 -
compareTo应与getDelay逻辑一致，推荐用Long.compare(getDelay(NANOSECONDS), other.getDelay(NANOSECONDS)) - 任务体（如
run()方法）不在此接口中定义，需额外添加，由消费者线程调用
用单个守护线程持续消费到期任务
最常见做法是启动一个单独的、非阻塞退出的后台线程，循环调用 take() —— 这个方法会阻塞直到有任务到期，天然适合延时调度场景。
-
take()是阻塞且响应及时的，无需 sleep 轮询，节省 CPU - 建议将该线程设为
daemon = true，避免阻止 JVM 退出 - 实际处理任务时，应捕获异常，防止一个任务失败导致整个调度线程中断
支持并发执行：用线程池处理取出的任务
DelayQueue 本身只负责“按时交付”，不负责“执行”。若希望多个延时任务并发运行（比如 10 个任务同时在 5 秒后触发），应在消费者线程中把取出的任务提交给线程池，而非串行执行。
立即学习“Java免费学习笔记（深入）”；
- 例如：
executor.submit(task::run)，这样每个任务在独立线程中运行，互不影响 - 线程池大小根据任务耗时和吞吐量调整；短平快任务可用
Executors.newCachedThreadPool()；长耗时任务建议固定大小 + 拒绝策略 - 务必注意任务内的共享资源是否线程安全，
DelayQueue不提供同步保障
注意边界与常见坑
DelayQueue 不是定时器，也不等价于 ScheduledThreadPoolExecutor。它更底层、更灵活，但也更需手动管理。
- 任务插入后不可修改延迟时间；如需取消，只能提前从队列中
remove(task)（效率较低，O(n)） - 如果多个任务在同一毫秒到期，
compareTo必须能稳定排序，否则可能因相等导致插入失败或顺序错乱 - JVM 时间跳变（如系统时间被手动调整）会影响
getDelay计算结果，生产环境建议用单调时钟（如System.nanoTime()做基准） - 内存泄漏风险：长期存活的未到期任务 + 强引用外部对象 → 注意任务对象尽量轻量、避免持有大对象或上下文
