DelayQueue使用

DelayQueue使用:DelayQueue是BlockingQueue的一种，所以它是线程安全的。时间到期后元素才能被取出使用,所以可以通过设置时间来控制元素输出顺序。使用DelayQueue首先需要实现Delayed：eg:@Datapublic class DelayItem  implements Delayed{/* 触发时间*/private long time;String delayKey;public DelayItem(String delayKey, long time, TimeUnit unit) {this.delayKey = delayKey;this.time = System.currentTimeMillis() + (time > 0 ? unit.toMillis(time) : 0);}@Overridepublic long getDelay(TimeUnit unit) {return time - System.currentTimeMillis();}@Overridepublic int compareTo(Delayed o) {DelayItem item = (DelayItem) o;long diff = this.time - item.time;if (diff <= 0) {// 改成>=会造成问题return -1;} else {return 1;}}}public class MemoryData {public static DelayQueue<DelayItem> delayQueue = new DelayQueue<>();}生产者可以通过redis记录详细数据,delatItem只记录redis的key。eg:redisBaseService.sAdd(key, value);DelayItem delayItem = new DelayItem(key, 1, TimeUnit.MINUTES);MemoryData.delayQueue.put(delayItem);消费者可以增加监听，每分钟监听延迟队列里是否存在到期数据，甚至启停服务时，将未处理的数据放入redis，下次起服务时,从redis中获取对应数据。eg:启动类:ConfigurableApplicationContext run =SpringApplication.run(Application.class, args);run.addApplicationListener(new DataMergeContainer());使用类:@Componentpublic class DataMergeContainer implements ApplicationListener<ApplicationStartedEvent>, DisposableBean {private static final Logger log = LoggerFactory.getLogger(DataMergeContainer.class);@Autowiredprivate RedisBaseService redisBaseService;private void peakData() {while (MemoryData.delayQueue.isEmpty()) {try {Thread.sleep(60000);} catch (InterruptedException e) {log.error("peakData sleep error", e);}}if (MemoryData.delayQueue.size() > 0) {for (int i = 0; i < MemoryData.delayQueue.size(); i++) {DelayItem take;try {take = MemoryData.delayQueue.take();String delayKey = take.getDelayKey();if (!StringUtils.isBlank(delayKey)) {//业务使用}} catch (InterruptedException e) {log.info("peakData getData error", e);}}}//递归处置peakData();}@Overridepublic void onApplicationEvent(ApplicationStartedEvent event) {log.info("DataMergeContainer start.....");while (redisBaseService.sSize("上次关闭服务记录数据的key") > 0) {String key= (String) redisBaseService.sPop("上次关闭服务记录数据的key");DelayItem delayItem = new DelayItem(key, 1, TimeUnit.MINUTES);MemoryData.delayQueue.put(delayItem);}new Thread(() -> {peakData();}).start();log.info("peakData getData start...");}@Overridepublic void destroy() {for (int i = 0; i < MemoryData.delayQueue.size(); i++) {DelayItem take;try {take = MemoryData.delayQueue.take();if (StringUtils.isNotBlank(take.getDelayKey())) {redisBaseService.sAdd("未处理完的服务记录数据的key", take.getDelayKey());}} catch (InterruptedException e) {log.info("peakData getData error", e);}}}}由于项目使用的是rabbitmq而非RocketMQ,否则使用RocketMQ的延迟消息机制会更方便,根据业务场景不同，可以使用不同的实现机制
包括不限于延迟队列，消息，定时任务等

DelayQueue使用相关推荐

【Java并发编程】20、DelayQueue实现订单的定时取消
当订单定时取消需要修改数据库订单状态,但是怎么确定订单什么时候应该改变状态,解决方案有下面两种: 第一种,写个定时器去每分钟扫描数据库,这样更新及时,但是如果数据库数据量大的话,会对数据库造成很大的 ...
java加载c库阻塞_【死磕Java並發】-----J.U.C之阻塞隊列：DelayQueue
DelayQueue是一個支持延時獲取元素的無界阻塞隊列.里面的元素全部都是"可延期"的元素,列頭的元素是最先"到期"的元素,如果隊列里面沒有元素到期,是不能從 ...
每日一博 - DelayQueue阻塞队列源码解读
文章目录 Pre DelayQueue特征 Leader/Followers模式 DelayQueue源码分析类继承关系核心方法成员变量构造函数入队方法 offer(E e) 出队方法 po ...
Java DelayQueue延迟队列的使用和源码分析
文章目录概述示例原理分析概述 DelayQueue 是JAVA提供的延时队列,队列内部的对象必须实现 Delayed 接口,该接口只有一个 getDelay 方法,返回延迟执行的时长. pub ...
使用DelayQueue 和 FutureTask 实现java中的缓存
使用DelayQueue.ConcurrentHashMap.FutureTask实现的缓存工具类. DelayQueue 简介 DelayQueue是一个支持延时获取元素的无界阻塞队列.DelayQ ...
DelayQueue源码
介绍一个实现PriorityBlockingQueue实现延迟获取的无界队列,在创建元素时,可以指定多久才能从队列中获取当前元素.只有延时期满后才能从队列中获取元素.(DelayQueue可以运用在 ...
DelayQueue详解
一.DelayQueue是什么 DelayQueue是一个无界的BlockingQueue,用于放置实现了Delayed接口的对象,其中的对象只能在其到期时才能从队列中取走.这种队列是有序的,即队头对 ...
java中DelayQueue的使用
文章目录简介 DelayQueue DelayQueue的应用总结 java中DelayQueue的使用简介今天给大家介绍一下DelayQueue,DelayQueue是BlockingQue ...
阻塞队列之七：DelayQueue延时队列
一.DelayQueue简介是一个无界的BlockingQueue,用于放置实现了Delayed接口的对象,其中的对象只能在其到期时才能从队列中取走.这种队列是有序的(PriorityQueue实际 ...
delayqueue_在DelayQueue中更改延迟，从而更改顺序
delayqueue 因此,我正在考虑构建一个简单的对象缓存,该缓存在给定时间后会使对象过期. 显而易见的机制是使用Java并发包中的DelayedQueue类. 但是我想知道是否有可能在将对象添加到 ...

DelayQueue使用

DelayQueue使用相关推荐

最新文章

热门文章