null - 程序员宅基地

定时任务实现的关键DelayQueue延迟队列_delayqueue队列中数据时间一致怎么先后执行-程序员宅基地

技术标签： java 队列

之前学习定时任务线程池（ScheduledThreadPoolExecutor）时发现它主要依赖线程池和它的静态内部类DelayedWorkQueue实现。而DelayedWorkQueue就是一种延迟队列，今天学习是并发包提供的延迟队列（DelayQueue）。

延迟队列说明

延迟队列提供的功能是在指定时间点才能获取队列元素的功能，队列最前面的元素是最优先执行的元素。

列举一下使用场景可能能够更加好理解，比如缓存系统的设计，缓存中的对象，指定了过期时间，到了过期时间就需要从缓存中移出；在比如任务调度系统，要准确在任务规定的时间点执行任务。这些场景如果我们不使用延迟队列，就必须不同的遍历所有缓存、任务然后判断是否需要移除缓存、执行任务。

而延迟队列则不需要不停的扫描缓存、任务，它能够实现能够实现在准确的时间点去执行任务。

接下来我们梳理一下缓存准时移除的实现，首先我们知道每个缓存的过期时间，就可以计算出每个缓存过期的时间戳，我们首先根据过期时间戳作为比较放到优先级队列（上一篇文章介绍的优先级队列）中，然后从优先级队列获取缓存，肯定是获取到最先需要过期的缓存，判断缓存是否到了过期时间，如果没到则把线程阻塞（过期时间戳与当前时间戳的差值），一定时间后线程自动唤醒，再次验证发现缓存刚好到期，可以移除缓存。

同样定时任务的准时执行也一样，只不过是把缓存过期的时间戳换成定时任务下次执行时间戳作为比较依据。

通过分析发现要实现这个功能需要一个优先级队列，保存的元素要指定移除队列的时间戳。

DelayQueue属性介绍

从上一步分析得出延迟队列必须拥有优先级队列的功能，同时保存的元素要有确定移除队列的时间，那么我们来看DelayQueue具体实现，基本属性源码如下图：

1结构.png

可以看到它利用优先级队列q用来保存数据，那么就拥有了优先级队列的全部功能。

接着看它所能存储的元素都必须继承Delayed，查看Delayed源码发现它继承了Comparable接口，并且声明了方法“long getDelay(TimeUnit unit);”，这个方法的说明翻译过来是：以给定的时间单位返回与此对象关联的剩余延迟。它可以直接得出对象剩余延迟，就像缓存的剩余时间，就可以执行获取到对象的线程阻塞时间。

那么继承至Delayed的对象就同时拥有了优先级队列需要的Comparable的实现和对象剩余延迟执行的时间。

DelayQueue关键实现

直接看take方法的实现，源码如下图：

2实现.png

只要上一篇文章弄懂了优先级队列，在看延迟队列的代码就很简单了。首先利用的是优先级队列获取元素，然后调用getDelay（Delayed接口声明的）方法判断是否阻塞以及阻塞时间。

可以看到第一个线程进来了如果发现节点为null则是不限阻塞时间的阻塞，而后面进来的线程如果发现leader不为null也是直接阻塞，后面的线程可以通过leader线程执行完后唤醒，那么leader线程是什么时候唤醒呢？

leader无限阻塞的原因是队列中没有数据，所以要唤醒肯定就是添加数据的地方，在offer方法保存元素成功后会验证队列最前面的是不是刚刚保存的元素，如果是则会调用available.signal();唤醒线程，代码比较简单就不贴出来了。

延迟队列最佳实践

延迟队列要说最佳实践就要说到前面提交的定时任务了，在之前分析定时任务线程池ScheduledThreadPoolExecutor提到过，所以我们直接来看ScheduledThreadPoolExecutor中的实现，关键源码如下图：

3最佳实践.png

每个任务在放到任务队列前都会设置下次执行时间time，如上图通过time实现了getDelay和compareTo方法，这样一个线程池就可以保存多个定时任务，每个任务在执行完后会重置time然后继续放到线程池的优先级队列中，就是如此的简单的实现了定时任务。

总结

在弄懂了优先级队列后在看延迟队列还是很简单的，无非是在优先级队列的基础上扩展了一丁点的功能，如何实现定时任务也就很简单了。

Java程序员日常学习笔记，如理解有误欢迎各位交流讨论！

本文链接：https://blog.csdn.net/weixin_46421629/article/details/108653208

原作者删帖不实内容删帖广告或垃圾文章投诉

智能推荐

while循环&CPU占用率高问题深入分析与解决方案_main函数使用while(1)循环cpu占用99-程序员宅基地

文章浏览阅读3.8k次，点赞9次，收藏28次。直接上一个工作中碰到的问题，另外一个系统开启多线程调用我这边的接口，然后我这边会开启多线程批量查询第三方接口并且返回给调用方。使用的是两三年前别人遗留下来的方法，放到线上后发现确实是可以正常取到结果，但是一旦调用，CPU占用就直接100%(部署环境是win server服务器)。因此查看了下相关的老代码并使用JProfiler查看发现是在某个while循环的时候有问题。具体项目代码就不贴了，类似于下面这段代码。while(flag) {//your code;}这里的flag._main函数使用while(1)循环cpu占用99

【无标题】jetbrains idea shift f6不生效_idea shift +f6快捷键不生效-程序员宅基地

文章浏览阅读347次。idea shift f6 快捷键无效_idea shift +f6快捷键不生效

node.js学习笔记之Node中的核心模块_node模块中有很多核心模块,以下不属于核心模块,使用时需下载的是-程序员宅基地

文章浏览阅读135次。Ecmacript 中没有DOM 和 BOM核心模块Node为JavaScript提供了很多服务器级别，这些API绝大多数都被包装到了一个具名和核心模块中了，例如文件操作的 fs 核心模块，http服务构建的http 模块 path 路径操作模块 os 操作系统信息模块// 用来获取机器信息的var os = require('os')// 用来操作路径的var path = require('path')// 获取当前机器的 CPU 信息console.log(os.cpus._node模块中有很多核心模块,以下不属于核心模块,使用时需下载的是

数学建模【SPSS 下载-安装、方差分析与回归分析的SPSS实现(软件概述、方差分析、回归分析)】_化工数学模型数据回归软件-程序员宅基地

文章浏览阅读10w+次，点赞435次，收藏3.4k次。SPSS 22 下载安装过程7.6 方差分析与回归分析的SPSS实现7.6.1 SPSS软件概述1 SPSS版本与安装2 SPSS界面3 SPSS特点4 SPSS数据7.6.2 SPSS与方差分析1 单因素方差分析2 双因素方差分析7.6.3 SPSS与回归分析SPSS回归分析过程牙膏价格问题的回归分析_化工数学模型数据回归软件

利用hutool实现邮件发送功能_hutool发送邮件-程序员宅基地

文章浏览阅读7.5k次。如何利用hutool工具包实现邮件发送功能呢？1、首先引入hutool依赖<dependency> <groupId>cn.hutool</groupId> <artifactId>hutool-all</artifactId> <version>5.7.19</version></dependency>2、编写邮件发送工具类package com.pc.c..._hutool发送邮件

docker安装elasticsearch，elasticsearch-head，kibana，ik分词器_docker安装kibana连接elasticsearch并且elasticsearch有密码-程序员宅基地

文章浏览阅读867次，点赞2次，收藏2次。docker安装elasticsearch，elasticsearch-head，kibana，ik分词器安装方式基本有两种，一种是pull的方式，一种是Dockerfile的方式，由于pull的方式pull下来后还需配置许多东西且不便于复用，个人比较喜欢使用Dockerfile的方式所有docker支持的镜像基本都在https://hub.docker.com/docker的官网上能找到合..._docker安装kibana连接elasticsearch并且elasticsearch有密码

随便推点

Python 攻克移动开发失败！_beeware-程序员宅基地

文章浏览阅读1.3w次，点赞57次，收藏92次。整理 | 郑丽媛出品 | CSDN（ID：CSDNnews）近年来，随着机器学习的兴起，有一门编程语言逐渐变得火热——Python。得益于其针对机器学习提供了大量开源框架和第三方模块，内置..._beeware

Swift4.0_Timer 的基本使用_swift timer 暂停-程序员宅基地

文章浏览阅读7.9k次。//// ViewController.swift// Day_10_Timer//// Created by dongqiangfei on 2018/10/15.// Copyright 2018年飞飞. All rights reserved.//import UIKitclass ViewController: UIViewController { ..._swift timer 暂停

元素三大等待-程序员宅基地

文章浏览阅读986次，点赞2次，收藏2次。1.硬性等待让当前线程暂停执行，应用场景：代码执行速度太快了，但是UI元素没有立马加载出来，造成两者不同步，这时候就可以让代码等待一下，再去执行找元素的动作线程休眠，强制等待 Thread.sleep(long mills)package com.example.demo;import org.junit.jupiter.api.Test;import org.openqa.selenium.By;import org.openqa.selenium.firefox.Firefox.._元素三大等待