DelayQueue延时队列示例
2024-08-31 12:17:21
介绍:
DelayQueue是一个无界阻塞队列,只有在延迟期满时才能从中提取元素。该队列的头部是延迟期满后保存时间最长的Delayed 元素。
使用场景:
缓存系统的设计,缓存中的对象,超过了空闲时间,需要从缓存中移出;任务调度系统,能够准确的把握任务的执行时间。
我们可能需要通过线程处理很多时间上要求很严格的数据,如果使用普通的线程,我们就需要遍历所有的对象,一个一个的检 查看数据是否过期等,首先这样在执行上的效率不会太高,其次就是这种设计的风格也大大的影响了数据的精度。一个需要12:00点执行的任务可能12:01 才执行,这样对数据要求很高的系统有更大的弊端。由此我们可以使用DelayQueue。
使用方法:
为了具有调用行为,存放到DelayDeque的元素必须继承Delayed接口。Delayed接口使对象成为延迟对象,它使存放在DelayQueue类中的对象具有了激活日期。该接口强制执行下列两个方法。
- CompareTo(Delayed o):Delayed接口继承了Comparable接口,因此有了这个方法。
- getDelay(TimeUnit unit):这个方法返回到激活日期的剩余时间,时间单位由单位参数指定。
代码实现:
public class Test {
public static void main(String[] args) {
DelayQueue<DelayTask> queue = new DelayQueue<>();
queue.add(new DelayTask("1", new Date()));
queue.add(new DelayTask("2", new Date(System.currentTimeMillis()+1000)));
queue.add(new DelayTask("3", new Date(System.currentTimeMillis()+2000))); System.out.println("queue put done"); while(!queue.isEmpty()) {
try {
DelayTask task = queue.take();
System.out.println(task.name + ":" + System.currentTimeMillis()); } catch (InterruptedException e) {
e.printStackTrace();
}
}
} static class DelayTask implements Delayed {
private String name; private Date taskTime; public DelayTask(String name, Date taskTime) {
this.name = name;
this.taskTime = taskTime;
} @Override
public int compareTo(@Nonnull Delayed o) {
DelayTask delayTask = (DelayTask) o;
long diff = taskTime.getTime() - delayTask.getTaskTime().getTime();
if (diff > 0) {
return 1;
} else if (diff == 0) {
return 0;
} else {
return -1;
}
} @Override
public long getDelay(TimeUnit unit) {
return unit.convert(taskTime.getTime() - System.currentTimeMillis(), TimeUnit.MILLISECONDS);
} public String getName() {
return name;
} public void setName(String name) {
this.name = name;
} public Date getTaskTime() {
return taskTime;
} public void setTaskTime(Date taskTime) {
this.taskTime = taskTime;
}
}
}
输出结果:
最新文章
- 重新注册IIS
- 使用 SVG 动画实现弹性的页面元素效果
- AX 利用windows粘贴板功能实现批量数据快速导出EXCEL
- [转]详述DHCP服务器的三种IP分配方式
- Bios里,把SATA Mode Selection改为AHCI无法启动
- Django数据操作
- MapReduce链接作业
- Linux - 扩展
- C#截取字符串的方法小结
- Android开发手记(21) 遍历文件夹
- 把Orchard部署到Windows Azure Web Sites
- jquery实现横向导航
- 手把手教你创建「人物角色Persona」
- Eclipse - 安装lombok后注解无效
- MySQL 和 Oracle 在 MyBatis 使用中的区别
- 广播消费:允许一个 Group ID 所标识的所有 Consumer 都会各自消费某条消息一次。
- 控制 datetimepicker 显示位置
- octave画心形曲线
- COM组件三大接口IUnknown、IClassFactory、IDispatch。
- day1:vcp考试
热门文章
- [SharePoint2010开发入门经典]12、SPS2010安全管理
- 【配置属性】—Entity Framework实例详解
- Shell简单介绍
- Chisel Tutorial(一)——Chisel介绍
- Mysql中You can&#39;t specify target table for update in FROM clause错误的意思是说,不能先select出同一表中的某些值,再update这个表(在同一语句中)。
- unity3d面试题摘选(全)
- 用select拼接insert into,单引号转义
- Maven + SpringMVC + Mybatis
- 编程求解,输入两个整数n和m,从数列1,2,3,……n中随意取几个数,使其和等于m。要求将所有的可能组合列出来
- Crawler4j快速入门实例