Java DelayQueue实现任务延时示例讲解
作者:xiaoguangtouqiang 发布时间:2023-03-17 01:37:49
标签:Java,DelayQueue,延时
在项目中有使用到延时队列的场景,做个简单的记录说明;首先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
0
投稿
猜你喜欢
- 简介switch的新特性可是源远流长,早在JDK 12就以预览功能被引入了,最终在JDK 14成为了正式版本的功能:JEP 361: Swi
- 一、前言(吐槽+煽情+简介) &n
- 一棵二叉查找树是按二叉树结构来组织的。这样的树可以用链表结构表示,其中每一个结点都是一个对象。结点中除了数据外,还包括域left,right
- 在开发中,可能会遇到一对多的关系,这个时候,一条sql语句就难以胜任这个任务了。只能先执行一条sql,然后根据返回的结果,再做一次sql关联
- SessionSession对象用于获取与数据库的物理连接。 Session对象是重量轻,设计了一个互动是需要与数据库每次被实例化。持久化对
- C# Class写入Json/// <summary> /// 写入jso
- 本文实例为大家分享了Spring实现默认标签解析流程的具体代码,供大家参考,具体内容如下承接上文,进入parseBeanDefinition
- 返回Json实体类属性大小写问题总归上述问题Rt,其实今天开发刚遇到,当时找了半天为啥前台传参后台却接收不到,原来是返回的时候返回小写,但是
- 有时候我们需要在一个ArrayList的for循环中动态删除元素的需求, 废话不多说看代码List<Integer> list
- 一、前言让我们先理一下springfox与swagger的关系。swagger是一个流行的API开发框架,这个框架以“开放API声明”(Op
- 一、背景当我们在drools中编写规则时,有些时候存在重复的代码,那么我们是否可以将这些重复代码抽取出来,封装成一个function来调用呢
- 接口直接返回图片数据起因最近在做涉及到分享推广的业务,需要由业务员分享二维码进入推广页面,由于是新项目,前期预算和用量都有限,没有搭建对象存
- 前言:Java数据结构与算法专题会不定时更新,欢迎各位读者监督。本文从最简单的一个排序算法——桶排序开始,分析桶排序的实现思路,代码实现,性
- 利用apache ftp工具实现文件的上传下载和删除,具体如下1、下载相应的jar包 com
- java语言里包含了许多对设计模式的直接支持,如command模式,agent模式,observer模式等。虽然java提供的对
- 依赖的jar包:spring相关jar包版本:4.3.1.RELEASE<dependency> &l
- 1、使用 ctrl+F12打开类中所有方法的界面2、然后直接键盘中输入方法名称或者方法包含的字母,会自动模糊匹配相关方法名补充:idea快速
- 一.导入Netty依赖<dependency> <groupId>io.netty</group
- 如下所示:import java.security.MessageDigest;import java.security.NoSuchAlg
- Java 使用getClass().getResourceAsStream()方法获取资源之前想获取一个资源文件做一些处理,使用getCla