DelayQueue原理分析

2024-05-24 19:52
文章标签 分析 原理 delayqueue

本文主要是介绍DelayQueue原理分析,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

1.简介

DelayQueue同样也是适用于并发环境下的容器之一,该容器属于阻塞队列的一种,其底层数据结构是PriorityQueue,主要应用于执行定时任务和缓存过期删除的场景。
DelayQueue也是线程安全的,它通过内部的ReentrantLock实现了线程间的互斥访问。
DelayQueue要求其内部元素必须实现Delayed接口,并重写getDelay方法。默认情况下,DelayQueue会按照元素的到期时间进行升序排列,且仅当元素到期(getDelay() <= 0)时,才能取出该元素。

2.实现原理

  • 为了实现延时的语义,其内部采用PriorityQueue进行延时任务的存储与管理,通过强制每个元素实现Delayed接口以实现getDelaycompareTo方法,从而实现了延时低的任务优先被执行的目标。
  • 内部设置了一把ReentrantLock,从而实现了进程间的互斥访问,线程安全性得到保证。
  • 内部还配有Condition,通过awaitsignal方法来完成多线程间的唤醒与等待。

3.源码分析

3.1 类定义

DelayQueue的类定义(JDK17)")
DelayQueue继承自AbstractQueue,因此具有一些基本的队列的增删改查的模板操作;
同时,它还实现了BlockQueue接口,因此该队列将具备阻塞队列的一些性质。
此外,我们还注意到,DelayQueue的泛型参数必须为Delayed接口的子类,这也印证了我们上面所说的一点:DelayQueue的元素必须强制实现Delayed接口。
同时,Delayed接口又继承了Comparable接口,因此,DelayQueue中的元素天然具有可排序的特性。

Q:为什么要强制队列元素实现Delayed接口?
A
实现Delayed接口,具体来讲是实现其要求的getDelaycompareTo这两个方法。

  • 实现getDelay方法:用于指示延时任务的剩余延迟时间,作为执行线程衡量该延时任务目前能不能够被执行的标准。
  • 实现compareTo方法:用于作为内部PriorityQueue的排序标准,用于比较任务的优先级,以编排好当前延时任务队列的正确的执行顺序。

DelayQueue的继承实现链(JDK17)")

3.2 初始化

DelayQueue的构造方法源码(JDK17)")
构造方法逻辑很简单,对于有参构造函数,它将调用addAll方法,而在addAll中,待要添加的集合校验通过后,遍历整个集合并挨个儿调用add方法,而在add方法中又调用了offer方法,这个我们待会细说,最终如果一切没问题的话,那么modified将被置为true并返回,否则,只要有一个元素添加失败就会抛异常(往往是由于队列满导致的)。
调用链:有参构造 --> addAll --> 遍历调用add --> offer

3.3 关键字段说明

DelayQueue类中的部分关键字段(JDK17)")

  • qDelayQueue的核心,也是其底层数据结构,用于存放延时任务,后续任务的添加与执行都是要靠它来完成的。同时它作为一个优先级队列,会将任务按照其延时时间(通过重写Delayed接口的父接口Comparable中的compareTo方法)进行升序排序。
  • leader:执行延时任务的唯一线程,以防止多个线程争抢而使任务执行效率降低。(相当于领导者-追随者模式中的领导者)
  • available:唤醒因到来的时候队列为空而等待或者到来时已经有其他线程在处理任务而等待的线程或者满足这些条件而阻塞,实现了工作线程间的阻塞与唤醒。

3.4 添加

DelayQueue的部分添加(生产)元素的方法(JDK17)元素的方法(JDK17)")
你会发现,不论是add方法还是put方法,都是直接调用的offer方法,因此,这里我们只分析offer执行流程

  1. 加锁。
  2. 调用内部PriorityQueue上的offer方法添加元素。
  3. 判断添加了该元素后的PriorityQueue中的头部元素是不是当前添加进入的元素(即当前所添加的元素是不是延时最短的那个),若是,则置leader线程为null,同时唤醒阻塞在available条件上的线程;否则,不做任何处理。
  4. 释放锁。

3.5 删除(执行延时任务)

DelayQueue的执行延时任务的方法(JDK17)")
**poll**方法的执行流程

  1. 加锁。
  2. 调用PriorityQueuepeek方法,试探性的取一下队头元素。
  3. 若发现队头元素(延时任务)为null或者还没到达预定的延时时间,则返回null;否则,调用poll方法将该元素出队并返回。
  4. 释放锁。

**take**方法的执行流程

  1. 加锁。
  2. 试探性的取到队列的头部元素:
    1. 如果头部元素为null,则说明队列目前没有延时任务可供消费,因此阻塞在available条件上。
    2. 若头部元素不为null
      1. 如果该元素已到达或者超过延时时间,则调用poll方法出队并返回。
      2. 若还未到达延时时间,则查看一下当前领导者线程是否为空:
        1. 若不为空,则说明目前已经有线程正在处理延时任务,因此我们需要阻塞等待,因此在available条件上阻塞。
        2. 若为空,则令当前线程作为领导者线程,然后阻塞等待至预定的延时执行时间,等待一段时间后,再次将主线程置为null,然后进入到for循环的下一次循环,进入到b -> i分支,处理延时任务(这也是为什么设置for循环的原因)。
  3. 最后的最后,如果领导者线程为null并且队列中还有延时任务,则随机唤醒阻塞在available条件上的线程以进行下一个延时任务的等待&处理。
  4. 释放锁。

上述过程其实用到了一个设计模式:领导者-追随者模式。

通过过程分析,不难发现,poll是非阻塞式删除,take是阻塞式删除。

3.6 获取

DelayQueue的获取但不移除元素的方法(JDK17)")
执行流程

  1. 加锁。
  2. 调用PriorityQueuepeek方法,然后直接返回该元素。
  3. 释放锁。

3.7 获取元素数量

DelayQueue的获取元素数量的方法(JDK17)")
执行流程

  1. 加锁。
  2. 调用PriorityQueuesize方法并返回。
  3. 释放锁。

4.评估

如果线程数量过少,且处理的任务耗时较长,而后续延时任务的到期时间相对集中,那么可能会使得后面的延时任务出现延期处理的情况。
线程数量过多也不见得是一件好事,因为这将在线程调度、同步方面花费更多的时间。
(当然,DelayQueue的工作线程的数量固定为1,上面是针对[领导者-追随者模式](https://www.yuque.com/jujingyi-mzjzr/ybr4gh/ix3ifmtyb3rfllxf) + DelayQueue而言的)

参考文档

DelayQueue 源码分析
Java 延迟队列 DelayQueue 的原理

这篇关于DelayQueue原理分析的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/999376

相关文章

怎样通过分析GC日志来定位Java进程的内存问题

《怎样通过分析GC日志来定位Java进程的内存问题》:本文主要介绍怎样通过分析GC日志来定位Java进程的内存问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、GC 日志基础配置1. 启用详细 GC 日志2. 不同收集器的日志格式二、关键指标与分析维度1.

从原理到实战深入理解Java 断言assert

《从原理到实战深入理解Java断言assert》本文深入解析Java断言机制,涵盖语法、工作原理、启用方式及与异常的区别,推荐用于开发阶段的条件检查与状态验证,并强调生产环境应使用参数验证工具类替代... 目录深入理解 Java 断言(assert):从原理到实战引言:为什么需要断言?一、断言基础1.1 语

MySQL中的表连接原理分析

《MySQL中的表连接原理分析》:本文主要介绍MySQL中的表连接原理分析,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录1、背景2、环境3、表连接原理【1】驱动表和被驱动表【2】内连接【3】外连接【4编程】嵌套循环连接【5】join buffer4、总结1、背景

深度解析Spring AOP @Aspect 原理、实战与最佳实践教程

《深度解析SpringAOP@Aspect原理、实战与最佳实践教程》文章系统讲解了SpringAOP核心概念、实现方式及原理,涵盖横切关注点分离、代理机制(JDK/CGLIB)、切入点类型、性能... 目录1. @ASPect 核心概念1.1 AOP 编程范式1.2 @Aspect 关键特性2. 完整代码实

python中Hash使用场景分析

《python中Hash使用场景分析》Python的hash()函数用于获取对象哈希值,常用于字典和集合,不可变类型可哈希,可变类型不可,常见算法包括除法、乘法、平方取中和随机数哈希,各有优缺点,需根... 目录python中的 Hash除法哈希算法乘法哈希算法平方取中法随机数哈希算法小结在Python中,

Java Stream的distinct去重原理分析

《JavaStream的distinct去重原理分析》Javastream中的distinct方法用于去除流中的重复元素,它返回一个包含过滤后唯一元素的新流,该方法会根据元素的hashcode和eq... 目录一、distinct 的基础用法与核心特性二、distinct 的底层实现原理1. 顺序流中的去重

Spring @Scheduled注解及工作原理

《Spring@Scheduled注解及工作原理》Spring的@Scheduled注解用于标记定时任务,无需额外库,需配置@EnableScheduling,设置fixedRate、fixedDe... 目录1.@Scheduled注解定义2.配置 @Scheduled2.1 开启定时任务支持2.2 创建

关于MyISAM和InnoDB对比分析

《关于MyISAM和InnoDB对比分析》:本文主要介绍关于MyISAM和InnoDB对比分析,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录开篇:从交通规则看存储引擎选择理解存储引擎的基本概念技术原理对比1. 事务支持:ACID的守护者2. 锁机制:并发控制的艺

Spring Boot 实现 IP 限流的原理、实践与利弊解析

《SpringBoot实现IP限流的原理、实践与利弊解析》在SpringBoot中实现IP限流是一种简单而有效的方式来保障系统的稳定性和可用性,本文给大家介绍SpringBoot实现IP限... 目录一、引言二、IP 限流原理2.1 令牌桶算法2.2 漏桶算法三、使用场景3.1 防止恶意攻击3.2 控制资源

Python中使用uv创建环境及原理举例详解

《Python中使用uv创建环境及原理举例详解》uv是Astral团队开发的高性能Python工具,整合包管理、虚拟环境、Python版本控制等功能,:本文主要介绍Python中使用uv创建环境及... 目录一、uv工具简介核心特点:二、安装uv1. 通过pip安装2. 通过脚本安装验证安装:配置镜像源(可