Java DelayQueue实现任务延时示例讲解
作者:xiaoguangtouqiang 时间:2023-03-17 01:37:49
在项目中有使用到延时队列的场景,做个简单的记录说明;首先DelayQueue实现了BlockingQueue,加入其中的元素必须实现Delayed接口;
当生产者元素调用put往其中加入元素时,出发Delayed接口的compareTo方法进行排序,这个排序是按照时间的,按照计划执行的时间排序,先执行的在前面,后执行的排后面;消费者获取元素时,调用getDelay方法返回的值大于0,则消费者线程wait返回的这个时间后,再从队列头部取出元素;下面是个简单的例子
import org.jetbrains.annotations.NotNull;
import java.util.Date;
import java.util.concurrent.Delayed;
import java.util.concurrent.TimeUnit;
public class DelayEntity implements Delayed {
private static final Long currentTime = System.currentTimeMillis();
private String str;
private Long scheduleTime;
public DelayEntity(String str, Long delayed) {
this.str = str;
scheduleTime = System.currentTimeMillis() + (1000) * delayed;
}
@Override
public long getDelay(@NotNull TimeUnit unit) {
return unit.convert(scheduleTime - System.currentTimeMillis(), TimeUnit.MILLISECONDS);
}
@Override
public int compareTo(@NotNull Delayed o) {
return (int) (this.scheduleTime - ((DelayEntity) o).scheduleTime);
}
public String getStr() {
return str;
}
public Long getScheduleTime() {
return scheduleTime;
}
public String showScheduleTime() {
return "计划执行时间:" + new Date(this.scheduleTime).toString();
}
}
@Test
public void test() throws InterruptedException {
DelayQueue<DelayEntity> delayQueue = new DelayQueue<>();
delayQueue.put(new DelayEntity("1", 1l));
delayQueue.put(new DelayEntity("2", 2l));
delayQueue.put(new DelayEntity("4", 3l));
while (true) {
DelayEntity take = delayQueue.take();
System.out.println("参数:" + take.getStr() + ";计划执行时间:" + take.showScheduleTime() + ";实际执行时间:" + new Date().toString());
}
}
下面看下take方法
public E take() throws InterruptedException {
final ReentrantLock lock = this.lock;
lock.lockInterruptibly();
try {
for (;;) {
E first = q.peek();
if (first == null)
available.await();
else {
long delay = first.getDelay(NANOSECONDS);
if (delay <= 0)
return q.poll();
first = null; // don't retain ref while waiting
if (leader != null)
available.await();
else {
Thread thisThread = Thread.currentThread();
leader = thisThread;
try {
available.awaitNanos(delay);
} finally {
if (leader == thisThread)
leader = null;
}
}
}
}
} finally {
if (leader == null && q.peek() != null)
available.signal();
lock.unlock();
}
}
这里可以看到,他不是一直循环的,是获取到第一个元素的delay等待的时间,之后等待这个时间才去唤醒其他线程;
另外,添加元素时,add方法和put方法都是调用的offer方法,区别是一个返回值,一个没有;
延伸下BlockingQueue的几个常用的操作;
1.offer方法是BlockingQueue的,offer不会阻塞执行的方法,可以添加返回true,否则返回false;
2.BlockingQueue的put方法,如果没有空间,会阻塞一直等到有空间
3.poll获取元素,不会阻塞,获取不到就返回null;
4.take,获取不到就阻塞
来源:https://blog.csdn.net/xiaoguangtouqiang/article/details/124109337
标签:Java,DelayQueue,延时
0
投稿
猜你喜欢
Spring Batch批处理框架使用解析
2021-12-24 03:41:19
详解Java虚拟机管理的内存运行时数据区域
2023-12-04 01:32:35
JavaFx 实现按钮防抖功能
2023-03-20 07:34:48
C#(int)中Convert、Parse、TryParse的区别
2023-06-25 03:19:50
springAop实现权限管理数据校验操作日志的场景分析
2023-11-23 10:00:27
详解java 三种调用机制(同步、回调、异步)
2023-11-25 07:59:57
Spring Security实现自动登陆功能示例
2023-01-29 15:31:55
springboot结合maven实现多模块打包
2022-01-16 07:13:51
通过实例解析java8中的parallelStream
2022-04-17 12:59:37
解决java 分割字符串成数组时,小圆点不能直接进行分割的问题
2023-11-05 03:13:24
SpringBoot+JSON+AJAX+ECharts+Fiddler实现前后端分离开发可视化
2021-11-12 14:49:17
深入理解ThreadLocal工作原理及使用示例
2022-02-27 19:24:14
Mybatis实现插入数据后返回主键过程解析
2022-07-14 18:43:15
java8新特性之日期时间API
2023-06-20 09:15:50
C#观察者模式(Observer Pattern)实例教程
2021-07-13 02:53:39
java 微信随机红包算法代码实例
2022-12-03 12:29:08
Maven默认中央仓库(settings.xml 配置详解)
2021-10-17 12:25:40
C#写入对象或集合类型数据到xml文件的方法
2022-11-12 17:11:37
windows系统配置Java开发环境变量
2022-03-07 23:28:07
java编程之基于SpringBoot框架实现扫码登录
2023-02-14 02:39:28