看看DelayQueue源码

这里能够看到DelayQueue类的层次结构。这是一个Delayed元素的无界阻塞队列，其中只有在延迟过时时才能获取元素。队列的头部的元素是根据继承的接口方法compareTo比较最小的。当元素的getDelay（TimeUnit.NANOSECONDS）方法返回小于或等于零的值时，会发生到期。即便使用take或poll没法删除未到期的元素，例如，size方法返回已过时和未过时元素的计数。

此队列不容许null元素。

该类及其迭代器实现了Collection和Iterator接口的全部可选方法。方法iterator（）中提供的迭代器不保证以任何特定顺序遍历DelayQueue的元素。

Delayed的结构，继承Comparable接口，并增长了 long getDelay(TimeUnit unit)方法，这个方法返回到激活日期的剩余时间，时间单位由单位参数指定。

该接口强制执行下列两个方法。

• CompareTo(Delayed o)：Delayed接口继承了Comparable接口，所以有了这个方法。
• getDelay(TimeUnit unit):这个方法返回到激活日期的剩余时间，时间单位由单位参数指定。

对这个类不是很熟悉，咱们来写个demo，写个Message实现Delayed接口

而后写一个DelayQueue来实现想要的功能

输出：

该类有两个构造方法

带参数的那个实际上执行的是offer方法，具体的实现仍是PriorityQueue的

这里获取值的时候用了take方法，检索并删除此队列的头部，必要时等待，直到此队列上有一个具备过时延迟的元素。这里用了ReentrantLock和Condition控制。

这里用的poll的方法也是颇有趣的，检索并删除此队列的头部，若是此队列没有具备过时延迟的元素，则返回null。

参考：https://docs.oracle.com/javase/9/docs/api/java/util/concurrent/DelayQueue.html