DelayQueue的使用

具体思路:
在容器初始化的时候就创建出一个 延迟队列 然后项目启动后随即启动一个线程一直监听这个队列
手动调用接口往队列中添加任务
依赖

一个最简单的web的应用即可

项目文件结构
在这里插入图片描述
第一步:在项目启动的时候就创建出一个延迟队列

@Configuration
public class DelayQueueConfig {@Beanpublic DelayQueue delayQueue() {return new DelayQueue();}
}

第二步:项目启动后开启一个线程去监听这个队列

/*ApplicationRunner的作用--项目启动后就执行run方法*/
@Component
public class BlockingQueueConsumer implements ApplicationRunner {@Autowiredprivate DelayQueue delayQueue;@Overridepublic void run(ApplicationArguments args) {/*开启一个线程 去监听 delayQueue*/new Thread(() -> {while (true) {try {Order order = (Order) delayQueue.take();order.run();} catch (InterruptedException e) {e.printStackTrace();}}}).start();}
}

当然,还需要创建出一个能放进队列的类

public class Order implements Delayed {private String orderNo;private long time;public Order(String orderNo, long time) {this.orderNo = orderNo;this.time = time;}@Override/*getDelay--获取现在还有多久才会被消费*/public long getDelay(TimeUnit unit) {return time - System.currentTimeMillis();}@Override/*决定队列中的顺序,谁在前 谁在后*/public int compareTo(Delayed o) {Order order = (Order) o;return Long.compare(this.time, order.time);}public void run() {System.out.println("订单号:" + orderNo + "已经被消费");}
}

最后,我们可以随时调用接口添加任务

@RestController
@RequestMapping("/blockingQueue")
public class BlockingQueueController {@Autowiredprivate DelayQueue delayQueue;@GetMapping("/test")public String test() {return "success";}@GetMapping("/add")public String add() {Order order = new Order("1", 3000+System.currentTimeMillis());Order order1 = new Order("2", 5000 + System.currentTimeMillis());Order order2 = new Order("3", 1000 + System.currentTimeMillis());delayQueue.put(order);delayQueue.put(order1);delayQueue.put(order2);return "success";}
}

结果
在这里插入图片描述

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.hqwc.cn/news/451935.html

如若内容造成侵权/违法违规/事实不符,请联系编程知识网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

明道云入选亿欧智库《AIGC入局与低代码产品市场的发展研究》

2023年12月27日,亿欧智库正式发布**《AIGC入局与低代码产品市场的发展研究》**。该报告剖析了低代码/零代码市场的现状和发展趋势,深入探讨了大模型技术对此领域的影响和发展洞察。其中,亿欧智库将明道云作为标杆产品进行了研究和分析。 明…

nodejs+vue+ElementU教师科研管理系统l33wm

本次开发一套高校教师科研管理系统有管理员,教师,学院三个角色。管理员功能有个人中心,教师管理,学院管理,科研课题管理,软件著作权管理,论文信息管理,专利信息管理,科研…

移动云ONAIR媒体云全解读!媒体内容数字化融合一站式解决方案

当下,传统媒体面临着诸多挑战,如何利用信息技术提升内容的质量、形式和分发效率,成为媒体行业的迫切需求。移动云作为数字中国建设的“主力军”, 立足于新兴媒体与云计算市场的变化与需求,推出了ONAIR 媒体云解决方案&…

【lesson9】高并发内存池Page Cache层释放内存的实现

文章目录 Page Cache层释放内存的流程Page Cache层释放内存的实现 Page Cache层释放内存的流程 如果central cache释放回一个span,则依次寻找span的前后page id的没有在使用的空闲span,看是否可以合并,如果合并继续向前寻找。这样就可以将切…

【Linux Day14 UDP网络通讯】

UDP网络通讯 UDP报文结构: 16位源端口:用于记录发送端的端口号(占用两个字节)16位目的端口:用于记录接收端的端口号(占用两个字节)16位UDP长度:确定UDP报文总长度,&…

Leetcode92:反转链表II(区间反转链表)

一、题目 给你单链表的头指针 head 和两个整数 left 和 right &#xff0c;其中 left < right 。请你反转从位置 left 到位置 right 的链表节点&#xff0c;返回 反转后的链表 。 示例&#xff1a; 输入&#xff1a;head [1,2,3,4,5], left 2, right 4 输出&#xff1a…

排序——选择排序

基本思想 每一趟在待排序元素中选取关键字最小的元素加入有序子序列。 算法代码 #include <iostream> using namespace std;//选择排序 void SelectSort(int nums[],int n){int i,j,min;for(i0;i<n-1;i){ //一共需要进行 n-1 趟 mini; //记录最小元素的下…

Java split 分割字符串避坑

使用split进行字符串分割时需要注意2点 1、特殊字符作为分隔符时需要使用\\进行转义(如\\ -> \\\\; | -> \\| ) 特殊字符 .$|()[{^?*\\ 例如对"|"分隔 未转义 String str "01|02|03"; String[] strArr str.split("|");System.out.…

【面试官问】Redis 持久化

目录 【面试官问】Redis 持久化 Redis 持久化的方式RDB(Redis DataBase)AOF(Append Only File)混合持久化:RDB + AOF 混合方式的持久化持久化最佳方式控制持久化开关主从部署使用混合持久化使用配置更高的机器参考文章所属专区

99例电气实物接线及52个自动化机械手动图

给大家分享一些流水线设计中常见的一些结构&#xff0c;这些动态图很直观&#xff0c;有助于大家了解其原理&#xff0c;非常好懂。 1.家庭总电箱接线图 2.经典双控灯接线 3.五孔一开接线 4.电动机点动控制接线&#xff08;不安全&#xff09; 5.电动机自锁接线图&#xff08;…

SpringBoot集成H2数据库

1&#xff09;添加H2的依赖 <dependency><groupId>com.h2database</groupId><artifactId>h2</artifactId><scope>compile</scope> </dependency>2&#xff09;添加连接配置&#xff0c;启用web控制台 spring:datasource:url…

【CSS】常见样式总结

一. 溢出隐藏 1.1 单行文本溢出 .content{max-width:200px; /* 定义容器最大宽度 */overflow:hidden; /* 隐藏溢出的内容 */text-overflow:ellipsis; /* 溢出部分...表示 */white-space: nowrap; /* 确保文本在一行内显示 */ }问题&#xff1a;display:flex 和 ellipsis 冲…