这里可以看到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