Java线程池队列DelayQueue的使用详解
作者：Brycen Liu
这篇文章主要介绍了Java线程池队列DelayQueue的使用详解,DelayQueue顾名思义,它是个无边界延迟队列,它的底层是基于PriorityBlockingQueue实现的,该队列中的元素都是按照过期时间顺序排序的,队列头部放的是即将过期的元素,需要的朋友可以参考下
Java线程池队列DelayQueue的使用及详细介绍
一、什么是DelayQueue？
DelayQueue顾名思义，它是个无边界延迟队列，它的底层是基于PriorityBlockingQueue实现的。
该队列中的元素都是按照过期时间顺序排序的，队列头部放的是即将过期的元素。
该队列中的元素必须实现Delayed接口，getDelay定义了剩余到期时间，compareTo方法定义了元素排序规则。
该队列不允许存放null元素。延时队列实现了Iterator接口，但Iterator()遍历顺序不保证是元素的实际存放顺序。
总结
- DelayQueue队列是无边界
- 队列中按照过期时间排序
- 队列中的元素必须实现Delayed接口
- 不允许存放null元素
- poll方法获取元素时，立即返回，如果没有过期的元素则返回null
- take方法获取元素时，如果没有过期的元素则会进行阻塞
- peek方法获取元素时，立即返回，不会删除该元素，即使没有过期的元素也会获取到
- 使用Iterator可以立即返回该队列中的元素，但是不保证顺序
二、案例
package com.brycen.part3.threadpool.collections;
import java.util.Iterator;
import java.util.concurrent.*;
public class DelayQueueExample {
public static void main(String[] args) throws InterruptedException {
DelayQueue<DelayElement> delayQueue = new DelayQueue<>();
delayQueue.add(new DelayElement<String>("test1",1000));
delayQueue.add(new DelayElement<String>("test2",800));
delayQueue.add(new DelayElement<String>("test3",2000));
delayQueue.add(new DelayElement<String>("test4",3000));
System.out.println("队列大小："+delayQueue.size());
//立即返回，同时删除元素，如果没有过期元素则返回null
System.out.println("poll方法获取："+delayQueue.poll());
//立即返回，不会删除元素，如果没有过期元素也会返回该元素，只有当队列为null时才会返回null
System.out.println("peek方法获取："+delayQueue.peek());
//进行阻塞
System.out.println("take方法获取："+delayQueue.take().getData());
//立即返回，但不能保证顺序
Iterator<DelayElement> iterator = delayQueue.iterator();
while (iterator.hasNext()){
DelayElement element = iterator.next();
System.out.println("iterator获取："+element.getData());
}
}
static class DelayElement<E> implements Delayed{
private final long expireTime;
private final E e;
public DelayElement(E e,long delay) {
this.expireTime = System.currentTimeMillis()+delay;
this.e = e;
}
@Override
public long getDelay(TimeUnit unit) {
//判断是否过期
return unit.convert(expireTime-System.currentTimeMillis(),TimeUnit.MILLISECONDS);
}
@Override
public int compareTo(Delayed delayed) {
//排序规则：按照过期时间排序
DelayElement that = (DelayElement)delayed;
if (this.expireTime<that.expireTime){
return -1;
}else if (this.expireTime>that.expireTime){
return 1;
}else {
return 0;
}
}
public E getData() {
return e;
}
}
}运行结果：
队列大小：4
poll方法获取：null
peek方法获取：com.brycen.part3.threadpool.collections.ArrayBlockingQueueExample$DelayElement@2437c6dc
take方法获取：test2
iterator获取：test1
iterator获取：test4
iterator获取：test3
到此这篇关于Java线程池队列DelayQueue的使用详解的文章就介绍到这了,更多相关Java线程池队列DelayQueue内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！