galaxy
  • Introduction
  • knowledge
    • JAVA
      • 多态
      • Socket
      • Servlet
      • HashMap
      • TCP
      • DelayQueue
      • Java反射
      • Java Proxy 和 CGLIB 动态代理
      • JVM
        • 类生命周期
        • JVM内存模型
        • 类加载器与双亲委派模型
        • JVM中堆和栈的区别
      • java.time
    • Spring
      • 常用注解
        • @Transactional
      • Spring Data JPA
      • AOP
      • IOC/DI
      • Spring 事务
      • Spring Boot 启动原理解析
      • Spring MVC
        • Spring MVC 2
      • MVC
    • 分布式
      • RPC框架
      • MQ
      • dubbo
        • 环境部署
        • demo
      • 分布式RPC框架性能大比拼
      • 序列化
      • ZK
        • 本地安装zk
        • ZK详解
      • 分布式
        • 分布式锁
      • 限流熔断技术
    • DB
      • Mysql
        • 索引
      • 事务
      • 数据库连接池
        • 工作原理
        • 连接池技术背景
        • 百度百科
        • 主流数据库连接池
      • MongoDB
        • 适用场景
        • MongoDB Java异步驱动快速指南
        • 异步Mongo驱动的性能测试
        • 使用规范
        • 使用场景2
      • Spring Data JPA
      • 数据库设计三大范式
      • 存储过程
      • 视图
      • 乐观锁与悲观锁
      • 分库分表
      • Redis3
        • 其它
        • Redis
        • 场景
        • 分布式及其它
    • Test
      • NGrinder
      • QPS与并发数
    • 并发编程
      • volatitle
      • 锁
      • ThreadLocal
      • AQS
      • CAS
      • RateLimiter
    • 线程池
      • Executors
      • ScheduledThreadPoolExecutor
      • 终止线程池原理
      • demo
  • MST目录
    • 算法&数据结构
      • 算法
      • 数据结构
      • 算法题
      • 经典算法
  • Tool
    • Git
    • Netty5
      • 一些案例
      • Netty源码分析
        • 一、服务器绑定过程分析
        • 二、线程模型分析
        • 三、Channel如何注册OP_ACCEPT, OP_READ, OP_WRITE
        • 四、事件分发模型
        • 五、ByteBuf缓冲区
        • 六、CodeC编解码分析
        • 七、异步执行Future和Promise
      • Netty5.0架构剖析和源码解读
    • idea
  • issue
    • Connection reset
    • 该如何从 Java 8 升级到 Java 10
    • 阿里巴巴为什么不用 ZooKeeper 做服务发现
  • Linux
    • command
Powered by GitBook
On this page
  • 概念:
  • 应用场景:

Was this helpful?

  1. knowledge
  2. JAVA

DelayQueue

PreviousTCPNextJava反射

Last updated 6 years ago

Was this helpful?

boke:

源码:

PriorityQueue:

概念:

延时队列,第一他是个队列,所以具有对列功能第二就是延时,这就是延时对列,功能也就是将任务放在该延时对列中,只有到了延时时刻才能从该延时对列中获取任务否则获取不到……

DelayQueue队列中每个元素都有个过期时间,并且队列是个优先级队列,当从队列获取元素时候,只有过期元素才会出队列。

DelayQueue类的主要作用:是一个无界的BlockingQueue,用于放置实现了Delayed接口的对象,其中的对象只能在其到期时才能从队列中取走。这种队列是有序的,即队头对象的延迟到期时间最长。注意:不能将null元素放置到这种队列中。

Delayed,一种混合风格的接口,用来标记那些应该在给定延迟时间之后执行的对象。此接口的实现必须定义一个 compareTo 方法,该方法提供与此接口的 getDelay 方法一致的排序。

简单的延时队列要有三部分:第一实现了Delayed接口的消息体、第二消费消息的消费者、第三存放消息的延时队列。

应用场景:

1、在打车软件中对订单进行派单的流程,当有订单的时候给该订单筛选司机,然后给当订单绑定司机,但是有时运气没那么好,订单进来后第一次没有筛选到合适的司机,但我们也不能就此结束派单,而是将该订单的信息放到延时队列中过个2秒钟在进行一次,其实这个2秒钟就是一个延迟,所以这里我们就可以使用延时队列来实现……

2、订餐业务/购物,当订单超过十分钟未支付的时候自动释放购物车中的商品,订单失效。

3、TimerQueue的内部实现

4、ScheduledThreadPoolExecutor中DelayedWorkQueue是对其的优化使用

public class DelayQueue<E extends Delayed> extends AbstractQueue<E>
    implements BlockingQueue<E> {

    private final transient ReentrantLock lock = new ReentrantLock();
    private final PriorityQueue<E> q = new PriorityQueue<E>();
http://ifeve.com/并发队列-无界阻塞延迟队列delayqueue原理探究/
https://www.jianshu.com/p/15f777b72716
https://www.cnblogs.com/CarpenterLee/p/5488070.html