技术文章 > java >  java基础 > 正文

DelayQueue解决java中延时提醒

小妮浅浅

对于DelayQueue的延迟的使用功能,我们可以利用这种特性,解决一些实例中涉及到延迟的问题。就拿消息的延迟举例,我们可以在之间就利用DelayQueue对这种消息进行时间上的设置,做一个消息的提醒功能。下面我们先来学一下DelayQueue的主要属性,然后对延迟提醒的实例进行代码分享。

1.主要属性

// 用于控制并发的锁
private final transient ReentrantLock lock = new ReentrantLock();
// 优先级队列
private final PriorityQueue<E> q = new PriorityQueue<E>();
// 用于标记当前是否有线程在排队(仅用于取元素时)
private Thread leader = null;
// 条件,用于表示现在是否有可取的元素
private final Condition available = lock.newCondition();

从属性我们可以知道,延时队列主要使用优先级队列来实现,并辅以重入锁和条件来控制并发安全。

2.延迟实例

下单完成,10分钟后,如果没有支付,发送消息,提醒支付。

发消息好解决,这里主要讨论延时的问题,Java里,有个DelayQueue,可以实现延时的功能。

public class Tt {
    private DelayQueue<OrderInfo> messageQueue = new DelayQueue<OrderInfo>(); //消息队列
    public static void main(String[] args) {
        Tt t = new Tt();
        OrderInfo oi = new OrderInfo("1", new Date().getTime() + 3000); // 加3000,表示延时3秒 
        OrderInfo oi2 = new OrderInfo("2", new Date().getTime() + 3000);
        t.messageQueue.offer(oi); // 当接收到订单后,往队列里放一条消息
        t.messageQueue.offer(oi2);
        System.out.println(new Date().toString() + "启动,并加入了两条消息"); // 模拟接收到了两个订单
        
        // 这里是消费线程,随程序运行启动
        t.handle();
    }
    private void handle() {
        ThreadPoolHolder.getThreadPool().submit(new Runnable() {
            @Override
            public void run() {
                while (true) {
                    try {
                        OrderInfo message = messageQueue.take(); // take方法,有消息(延时时间<0的消息)取消息,没有,阻塞住。
                        // 这里查一遍订单.. 符合需求发消息,不符合不发
                        System.out.println(new Date().toString() + " ..... 发送消息id " + message.getId());
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }
        });
    }
}
// 消息体,必须实现Delayed接口
public class OrderInfo implements Delayed {
 
    private String id;
 
    public OrderInfo(String id, long excuteTime) {
        this.id = id;
        this.excuteTime = excuteTime;
    }
 
    private long excuteTime;// 延迟时长,这个是必须的属性因为要按照这个判断延时时长。
 
    public String getId() {
        return id;
    }
 
    @Override
    public long getDelay(TimeUnit unit) {
        return unit.convert(excuteTime,TimeUnit.NANOSECONDS) - unit.convert(System.currentTimeMillis(),TimeUnit.NANOSECONDS);
    }
 
    @Override
    public int compareTo(Delayed o) {
        OrderInfo msg = (OrderInfo) o;
        return Integer.valueOf(this.id) > Integer.valueOf(msg.id) ? 1
                : (Integer.valueOf(this.id) < Integer.valueOf(msg.id) ? -1 : 0);
    }
}

以上就是DelayQueue解决java中延时提醒的方法,当我们有类似需要提醒的功能设置时,可以选择DelayQueue的方法进行设定,学会后赶紧用在实例中吧。

免费视频教程
本文原创发布python学习网,转载请注明出处,感谢您的尊重!
相关文章
 java ArrayBlockingQueue的方法及不足点
 java中linkedblockingqueue用法
 linkedblockingqueue在java中的原理
 java中linkedblockingqueue的增加方法
 linkedblockingqueue在java中出队
 java中DelayQueue是什么
 java DelayQueue的原理
相关视频章节
 网络爬虫
 云端部署Web应用程序视频
 Web应用框架Flask和文件模板
 Web应用程序开发概述
 继承和多态
作者信息

小妮浅浅

认证0级讲师

最近文章
java编译命令是什么518
java的jdk是什么407
java Wrapper类的使用806
推荐视频
视频教程分类