17370845950

DelayQueue 是基于 PriorityQueue 和 ReentrantLock 实现的无界阻塞队列，元素须实现 Delayed 接口，按剩余延迟时间小顶堆排序，仅当 getDelay(TimeUnit.NANOSECONDS) ≤ 0 时可被取出。

DelayQueue 是 Java 并发包中一个专用于延迟任务调度的无界阻塞队列，它的核心不是“等时间到了再查”，而是靠一套协同机制精准、低开销地唤醒等待线程。

底层是 PriorityQueue + 线程安全锁

DelayQueue 内部封装了一个 PriorityQueue（小顶堆），所有元素按「剩余延迟时间」升序排列——堆顶永远是最快到期的元素。它不自己实现排序逻辑，而是强制要求存入的元素必须实现 Delayed 接口，靠 getDelay() 和 compareTo() 驱动排序与到期判断。

为保障多线程并发安全，它用一把 ReentrantLock 串行化所有读写操作，并配一个 Condition available 来管理等待线程的挂起与唤醒。

到期判断只看 getDelay() ≤ 0

元素能否被取出，唯一依据是：getDelay(TimeUnit.NANOSECONDS) 。这个方法必须返回「当前时刻到到期时刻的剩余纳秒数」。注意：不是设置绝对时间戳，而是动态计算差值。

• 返回正数 → 还没到期，take() 会继续等待
• 返回 0 或负数 → 已到期，可立即 poll/take

所以实现时通常用 expireTime - System.nanoTime()，而不是固定写死某个时间点。

Leader-Follower 模式减少无效唤醒

多个线程同时调用 take() 时，不会全部忙等或轮询。DelayQueue 采用轻量级 Leader-Follower 协作：

• 第一个进入 take 的线程成为 leader，它只 awaitNanos(delay)，精确等到堆顶元素到期
• 其余线程作为 follower，直接 await()，无限期挂起
• leader 取出元素后，signal() 唤醒一个 follower；新 leader 继续等待下一个堆顶的 delay

这样避免了所有线程反复检查、抢锁、发现未到期又释放锁的浪费，大幅提升高并发下的响应效率。

无界但需防内存泄漏

DelayQueue 没有容量限制，理论上可存任意多任务。但这也意味着：

• 生产者永远不会因队列满而阻塞（offer 总返回 true）
• 如果消费者太慢、或大量任务长期不过期，容易 OOM
• 建议配合监控或定期清理逻辑（比如用 ScheduledExecutorService 辅助扫描过期元数据）

基本上就这些。它不复杂，但 leader/follower 和动态 getDelay 计算是容易忽略的关键点。