- 当前位置：首页 >焦点 >面试侃集合 | DelayQueue篇
面试侃集合 | DelayQueue篇
发布时间：2025-11-05 10:42:12 来源：创站工坊 作者：数据库
面试官：好久不见啊，面试上次我们聊完了PriorityBlockingQueue，侃集今天我们再来聊聊和它相关的面试DelayQueue吧?
Hydra：就知道你前面肯定给我挖了坑，DelayQueue也是侃集一个无界阻塞队列，但是面试和之前我们聊的其他队列不同，不是侃集所有类型的元素都能够放进去，只有实现了Delayed接口的面试对象才能放进队列。Delayed对象具有一个过期时间，侃集只有在到达这个到期时间后才能从队列中取出。面试
面试官：有点意思，侃集那么它有什么使用场景呢?面试
Hydra：不得不说，由于DelayQueue的侃集精妙设计，使用场景还是面试蛮多的。例如在电商系统中，侃集如果有一笔订单在下单30分钟内没有完成支付，面试那么就需要自动取消这笔订单。还有，如果我们缓存了一些数据，并希望这些缓存在一定时间后失效的话，也可以使用延迟队列将它从缓存中删除。
以电商系统为例，可以简单看一下这个流程：
面试官：看起来和任务调度有点类似啊，它们之间有什么区别吗?
Hydra：任务调度更多的高防服务器偏向于定时的特性，是在指定的时间点或时间间隔执行特定的任务，而延迟队列更多偏向于在指定的延迟时间后执行任务。相对任务调度来说，上面举的例子中的延迟队列场景都具有高频率的特性，使用定时任务来实现它们的话会显得有些过于笨重了。
面试官：好了，你也白话了半天了，能动手就别吵吵，还是先给我写个例子吧。
Hydra：好嘞，前面说过存入队列的元素要实现Delayed接口，所以我们先定义这么一个类：
public class Task implements Delayed { private String name; private long delay,expire; public Task(String name, long delay) { this.name = name; this.delay = delay; this.expire=System.currentTimeMillis()+delay; } @Override public long getDelay(TimeUnit unit) { return unit.convert(this.expire - System.currentTimeMillis(), TimeUnit.MILLISECONDS); } @Override public int compareTo(Delayed o) { return (int)(this.getDelay(TimeUnit.MILLISECONDS) - o.getDelay(TimeUnit.MILLISECONDS)); } }实现了Delayed接口的类必须要实现下面的两个方法：
getDelay方法用于计算对象的剩余延迟时间，判断对象是否到期，计算方法一般使用过期时间减当前时间。如果是0或负数，表示延迟时间已经用完，云服务器提供商否则说明还没有到期 compareTo方法用于延迟队列的内部排序比较，这里使用当前对象的延迟时间减去被比较对象的延迟时间在完成队列中元素的定义后，向队列中加入5个不同延迟时间的对象，并等待从队列中取出：
public void delay() throws InterruptedException { DelayQueue<Task> queue=new DelayQueue<>(); queue.offer(new Task("task1",5000)); queue.offer(new Task("task2",1000)); queue.offer(new Task("task3",6000)); queue.offer(new Task("task4",100)); queue.offer(new Task("task5",3000)); while(true){ Task task = queue.take(); System.out.println(task); } }运行结果如下，可以看到按照延迟时间从短到长的顺序，元素被依次从队列中取出。
Task{name=task4, delay=100} Task{name=task2, delay=1000} Task{name=task5, delay=3000} Task{name=task1, delay=5000} Task{name=task3, delay=6000}面试官：看起来应用还是挺简单的，但今天也不能这么草草了事吧，还是说说原理吧。
Hydra：开始的时候你自己不都说了吗，今天咱们聊的DelayQueue和前几天聊过的PriorityBlockingQueue多少有点关系。DelayQueue的底层是PriorityQueue，而PriorityBlockingQueue和它的差别也没有多少，只是在PriorityQueue的基础上加上锁和条件等待，入队和出队用的都是亿华云计算二叉堆的那一套逻辑。底层使用的有这些：
private final transient ReentrantLock lock = new ReentrantLock(); private final PriorityQueue<E> q = new PriorityQueue<E>(); private Thread leader = null; private final Condition available = lock.newCondition();面试官：你这样也有点太糊弄我了吧，这就把我敷衍过去了?
Hydra：还没完呢，还是先看入队的offer方法，它的源码如下：
public boolean offer(E e) { final ReentrantLock lock = this.lock; lock.lock(); try { q.offer(e); if (q.peek() == e) { leader = null; available.signal(); } return true; } finally { lock.unlock(); } }DelayQueue每次向优先级队列PriorityQueue中添加元素时，会以元素的剩余延迟时间delay作为排序的因素，来实现使最先过期的元素排在队首，以此达到在之后从队列中取出的元素都是先取出最先到达过期的元素。
二叉堆的构造过程我们上次讲过了，就不再重复了。向队列中添加完5个元素后，二叉堆和队列中的结构是这样的：
当每个元素在按照二叉堆的顺序插入队列后，会查看堆顶元素是否刚插入的元素，如果是的话那么设置leader线程为空，并唤醒在available上阻塞的线程。
这里先简单的介绍一下leader线程的作用，leader是等待获取元素的线程，它的作用主要是用于减少不必要的等待，具体的使用在后面介绍take方法的时候我们细说。
面试官：也别一会了，趁热打铁直接讲队列的出队方法吧。
Hydra：这还真没法着急，在看阻塞方法take前还得先看看非阻塞的poll方法是如何实现的：
public E poll() { final ReentrantLock lock = this.lock; lock.lock(); try { E first = q.peek(); if (first == null || first.getDelay(NANOSECONDS) > 0) return null; else return q.poll(); } finally { lock.unlock(); } }代码非常短，理解起来非常简单，在加锁后首先检查堆顶元素，如果堆顶元素为空或没有到期，那么直接返回空，否则返回堆顶元素，然后解锁。
面试官：好了，铺垫完了吧，该讲阻塞方法的过程了吧?
Hydra：阻塞的take方法理解起来会比上面稍微困难一点，我们还是直接看它的源码：
public E take() throws InterruptedException { final ReentrantLock lock = this.lock; lock.lockInterruptibly(); try { for (;;) { E first = q.peek(); if (first == null) available.await(); else { long delay = first.getDelay(NANOSECONDS); if (delay <= 0) return q.poll(); first = null; // dont retain ref while waiting if (leader != null) available.await(); else { Thread thisThread = Thread.currentThread(); leader = thisThread; try { available.awaitNanos(delay); } finally { if (leader == thisThread) leader = null; } } } } } finally { if (leader == null && q.peek() != null) available.signal(); lock.unlock(); } }阻塞过程中分支条件比较复杂，我们一个一个看：
首先获取堆顶元素，如果为空，那么说明队列中还没有元素，让当前线程在available上进行阻塞等待 如果堆顶元素不为空，那么查看它的过期时间，如果已到期，那么直接弹出堆顶元素 如果堆顶元素还没有到期，那么查看leader线程是否为空，如果leader线程不为空的话，表示已经有其他线程在等待获取队列的元素，直接阻塞当前线程。 如果leader为空，那么把当前线程赋值给它，并调用awaitNanos方法，在阻塞delay时间后自动醒来。唤醒后，如果leader还是当前线程那么把它置为空，重新进入循环，再次判断堆顶元素是否到期。当有队列中的元素完成出队后，如果leader线程为空，并且堆中还有元素，就唤醒阻塞在available上的其他线程，并释放持有的锁。
面试官：我注意到一个问题，在上面的代码中，为什么要设置first = null呢?
Hydra：假设有多个线程在执行take方法，当第一个线程进入时，堆顶元素还没有到期，那么会将leader指向自己，然后阻塞自己一段时间。如果在这期间有其他线程到达，会因为leader不为空阻塞自己。
当第一个线程阻塞结束后，如果将堆顶元素弹出成功，那么first指向的元素应该被gc回收掉。但是如果还被其他线程持有的话，它就不会被回收掉，所以将first置为空可以帮助完成垃圾回收。
面试官：我突然有一个发散性的疑问，定时任务线程池ScheduledThreadPoolExecutor，底层使用的也是DelayQueue吗?
Hydra：问题很不错，但很遗憾并不是，ScheduledThreadPoolExecutor在类中自己定义了一个DelayedWorkQueue内部类，并没有直接使用DelayQueue。不过如果你看一下源码，就会看到它们实现的逻辑基本一致，同样是基于二叉堆的上浮、下沉、扩容，也同样基于leader、锁、条件等待等操作，只不过自己用数组又实现了一遍而已。说白了，看看两个类的作者，都是Doug Lea大神，所以差异根本没有多大。
面试官：好了，今天先到这吧，能最后再总结一下吗?
Hydra：DelayQueue整体理解起来也没有什么困难的点，难的地方在前面聊优先级队列的时候基本已经扫清了，新加的东西也就是一个对于leader线程的操作，使用了leader线程来减少不必要的线程等待时间。
面试官：今天的面试有点短啊，总是有点意犹未尽的感觉，看来下次得给你加点料了。
Hydra：…
- 不是我不明白，这世界变化快！微软面向 Linux 平台推出了 Visual Studio 2015！昔日的对头，如今正走向融合。这么喜大普奔的事，我准备挑战一下微软重量级软件在 Linux 平台上的安装。然没想到哇。根本没有我想象中的挑战性。看完你就知道了。软件名称：Visual Studio 2015 旗舰版 官方最新版软件大小：1.69MB更新时间：2014-11-171、百度 “Visual Studio Downloads”这一溜关键词，在搜索结果中打开 Visual Studio 的主页。2、可以看到页面上有三个磁贴状方块，最右边的是 Visual Studio Code，我们点击它里面的“下载”。3、进入下载页面，页面上地址栏下方的黄色条带里提示有更新的版本，当然，大家要更新的。先点那个黄条里的 New features，看看有啥新鲜东西。4、各种改进，包括文件管理、编辑器选项、JavaScript 支持升级、Git 增强等等。那还等什么，点击上方黄条上的 Update，去下载升级版吧。5、在接下来的页面，我们点击 Updating on Linux 一节里的链接，开始下载。有两个链接，分别是 64 位的和 32 位的，根据自己的情况选择。6、下载完成之后，点击下载管理器里的“在文件夹中显示”，导航到刚才下载的软件包所在的文件夹。7、在软件包上右键——>提取到此处，开始解压软件包。8、解压完成，进入与软件压缩包同名的文件夹，在一个名为 Code 的可执行文件上双击。9、DUANG！Linux 平台上的微软重量级软件一下出现在眼前。原来，Visual Studio Code 是不开源的，我刚开始想象的软件编译呀，软件包依赖呀等挑战，从开始就不存在好嘛。现在，各位年轻的码农，一切就看你们的了。10、假如和我一样觉得无从下手，好吧，附送免费视频培训，我的名字叫雷锋。
- Java中的JVM字符串性能优化
- 泛型，很多人因它放弃学习TypeScript？
- 微博给自家CEO加了“头发特效” 网友调侃：来去之间变莱芝简
- 探索T50P耳机的功能与优势（发现T50P耳机的卓越音质和舒适设计）
- 微信公众号崩溃了，然后呢？
- 冒着挂科的风险也要给你们看的 Spring Cloud 入门总结
- 一份微服务架构手稿图，彻底搞定微服务核心原理
- 升级好ubuntu15.04之后，却发现系统语言全是英文，该怎么设置中文呢，我这就把方法分享给大家。1、点击系统左侧菜单栏中的那个“扳手+齿轮”图标，该图标是打开系统设置的图标。2、打开上面的那个图标后。在第一行，我们使用鼠标左键点击，最后的那个像国旗的图标。它是语言支持图标哦，如下图，打开它。3、打开那个图标之后，点击窗口中，从上到下的第二个图标，我这里是这个界面是中文的，所以，大家知道是在干什么！点击那个位置的按钮就行啦。4、点开后，设置里面有很多语言类型，我们拉动滚动条，来找到我们需要的语言。5、勾选语言列表中的“中文简体”或叫“chinese(simplified)”，然后点击左下角的那个按钮，假如你的此界面和我一样，那么就是点击的应用变更按钮。假如是英文的，勾选然后点击那个位置的按钮即可。6、在弹出的验证窗口里面，我们需要输入密码才能做到系统语言的变更，那么我们输入电脑的密码，然后点击如图中位置的按钮即可。7、我们把在语言支持列表(第一个是English)中的汉语，拉到English上面去，意思是第一个系统语言。然后点击该界面下面的第一个按钮。如下图8、经过以上步骤，我们点击系统右上角的那个齿轮图标，然后再点击里面的“log out ”，即，倒数第三个选项。9、注销一次系统，注销之后，我们重新登陆，是不是系统成为中文的了呢？
- 动画：一个浏览器是如何工作的？
- 在Ubuntu下将chm文件转成pdf格式总共分为三个步骤：1.将chm提取出html文件： 2.将html按页排序 3.转换成pdf 在Ubuntu下进行如下操作：1.安装libchm-bin， htmldocsudo apt-get install libchm-bin htmldoc2.提取出html文件extract_chmLib 3.转换成pdfhtmldoc -t pdf13 --webpage -f myFile.pdf *.html
- 里程碑！国网吉林电力云平台和数据中台上线发布，率先推进泛在电力物联网建设迈向新阶段
- 华为Mate X设计很惊艳，但使用起来要注意
- Kubernetes设计的4个原则
- 以es护肤品怎么样？－挑选适合自己的护肤品（了解es护肤品的特点及使用经验，找到适合你的完美护肤方案）
- HTTPS详解一：附带最精美详尽的HTTPS原理图
- 你的分层架构还好吗？
- 7个令人兴奋的 JavaScript 新特性
- 电脑屏幕刷新率的重要性（高刷新率带来更好的视觉体验和游戏性能）
- 用于软件架构的 C4 模型
随便看看
- Copyright © 2025 Powered by 面试侃集合 | DelayQueue篇,创站工坊 滇ICP备2023006006号-44sitemap