java并发编程工具类JUC第三篇:DelayQueue延时队列

DelayQueue 是BlockingQueue接口的实现类，它根据"延时时间"来确定队列内的元素的处理优先级（即根据队列元素的"延时时间"进行排序）。另一层含义是只有那些超过"延时时间"的元素才能从队列里面被拿出来进行处理。

• DelayQueue 队列将阻止其元素对象从队列中被取出，直到达到为元素对象设置的延迟时间。DelayQueue 在队列的头部存储最近过期的元素，如果队列内没有元素过期，使用poll()方法获取队列内的元素将会返回null。
• DelayQueue 类及其迭代器实现了Collection和Iterator接口的所有可选方法，但迭代器方法iterator()不能保证以特定的顺序遍历DelayQueue的元素。

• DelayQueue 不接收null元素，DelayQueue 只接受那些实现了java.util.concurrent.Delayed接口的对象，并将其放入队列内。DelayQueue 通过调用元素对象的getDelay(TimeUnit) 方法获取该元素剩余的"延迟时间"。getDelay()的 TimeUnit时间单位是一个枚举类型 ： DAYS（天）, HOURS（小时）, MINUTES（分钟）, SECONDS（秒）, MILLISECONDS（毫秒）, MICROSECONDS（微妙）, NANOSECONDS（纳秒）

public interface Delayed extends Comparable{   long getDelay(TimeUnit unit);}

下面我们就写一个java Class实现Delayed 接口，只有实现了Delayed 接口的类对象才能放入DelayQueue。因为Delayed接口继承自Comparable接口，所以我们必须实现getDelay方法和compareTo方法。

class DelayObject implements Delayed { private String name;  private long time; //延时时间 public DelayObject(String name, long delayTime) {  this.name = name;  this.time = System.currentTimeMillis() + delayTime;  } @Override public long getDelay(TimeUnit unit) {  long diff = time - System.currentTimeMillis();  return unit.convert(diff, TimeUnit.MILLISECONDS); } @Override public int compareTo(Delayed obj) {  if (this.time < ((DelayObject)obj).time) {   return -1;  }  if (this.time > ((DelayObject)obj).time) {   return 1;  }  return 0; } @Override public String toString() {  Date date = new Date(time);  SimpleDateFormat sd = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");  return "\nDelayObject:{"  + "name=" + name  + ", time=" + sd.format(date)  + "}"; } } 

测试延时队列DelayQueue的使用效果

public class DelayQueueTest { @Test void testDelayObject() throws InterruptedException { //实例化一个DelayQueue BlockingQueue<DelayObject> DQ = new DelayQueue<>(); //向DelayQueue添加四个元素对象，注意延时时间不同 DQ.add(new DelayObject("A", 1000 * 10)); //延时10秒 DQ.add(new DelayObject("B", 4000 * 10)); //延时40秒 DQ.add(new DelayObject("C", 3000 * 10)); //延时30秒 DQ.add(new DelayObject("D", 2000 * 10)); //延时20秒 SimpleDateFormat sd = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); //将对象从DelayQueue取出，注意取出的顺序与延时时间有关 System.out.println( DQ.take()); //取出A System.out.println( DQ.take()); //取出D System.out.println( DQ.take()); //取出C System.out.println( DQ.take()); //取出B }}

从下面的打印结果及上文的代码可以看出

• 队列中元素放入的顺序是A、B、C、D，取出的顺序是A、D、C、B，这是因为队列中的元素按照延时时间进行了排序。
• 另外我们可以看到，每隔10秒才可以从队列中取出一个元素，这是因为只有超过"延时时间"的元素才能从队列里面被拿出来。而我们设置的延时时间是10s、20s、30s、40s。

DelayObject:{name=A, time=2021-03-23 14:14:20}DelayObject:{name=D, time=2021-03-23 14:14:30}DelayObject:{name=C, time=2021-03-23 14:14:40}DelayObject:{name=B, time=2021-03-23 14:14:50}

欢迎关注我的博客，里面有很多精品合集

• 本文转载注明出处（必须带连接，不能只转文字）：字母哥博客。

觉得对您有帮助的话，帮我点赞、分享！您的支持是我不竭的创作动力！ 。另外，笔者最近一段时间输出了如下的精品内容，期待您的关注。

• 《手摸手教你学Spring Boot2.0》
• 《Spring Security-JWT-OAuth2一本通》
• 《实战前后端分离RBAC权限管理系统》
• 《实战SpringCloud微服务从青铜到王者》
• 《VUE深入浅出系列》

原文转载：http://www.shaoqun.com/a/775044.html

跨境电商：https://www.ikjzd.com/

askme：https://www.ikjzd.com/w/2459

递四方：https://www.ikjzd.com/w/1066

DelayQueue是BlockingQueue接口的实现类，它根据"延时时间"来确定队列内的元素的处理优先级（即根据队列元素的"延时时间"进行排序）。另一层含义是只有那些超过"延时时间"的元素才能从队列里面被拿出来进行处理。DelayQueue队列将阻止其元素对象从队列中被取出，直到达到为元素对象设置的延迟时间。DelayQueue在队列的头部存储最近过期的元素，如果队列内没
薇美铺：https://www.ikjzd.com/w/2312
口述：女友买房心切逼我色诱富婆女友老板买房：http://lady.shaoqun.com/m/a/33695.html
旺店通：https://www.ikjzd.com/w/2390
跨境通电子商务：https://www.ikjzd.com/w/1329
口述疯狂的一次恋情 一夜情之后我爱上了他：http://lady.shaoqun.com/a/275170.html
背着女友偷腥 那夜我与她姐缠绵：http://www.30bags.com/a/252562.html
美媒：尽管平台明令禁止，但「TikTok」仍拥有大量多层营销内容：https://www.ikjzd.com/articles/145245
618预售增长背后 清洁科技品牌的竞争将如何演化？：https://www.ikjzd.com/articles/145243
速卖通海外仓如何申请开通？：https://www.ikjzd.com/articles/145229