DelayQueue

Posted 2020-09-13 gdpuzxs

　　DelayQueue是一个无界队列，只有在延迟期满的时候，才可以取出元素。该队列的头部存储的延期期满了后保存时间最长的元素。

　　DelayQueue阻塞队列在我们系统开发中也常常会用到，例如：缓存系统的设计，缓存中的对象，超过了空闲时间，需要从缓存中移出；任务调度系统，能够准确把握任务的执行时间。我们可能需要通过线程处理很多时间上要求很严格的数据，如果使用普通的线程，我们就需要遍历所有的对象，一个一个的检 查看数据是否过期等，首先这样在执行上的效率不会太高，其次就是这种设计的风格也大大的影响了数据的精度。一个需要12:00点执行的任务可能12:01 才执行,这样对数据要求很高的系统有更大的弊端。由此我们可以使用DelayQueue。

　　为了具有调用行为，存放到DelayDeque的元素必须继承Delayed接口。Delayed接口使对象成为延迟对象，它使存放在DelayQueue类中的对象具有了激活日期。

　　该接口强制执行下列两个方法。

　　CompareTo(Delayed o)：Delayed接口继承了Comparable接口，该方法是进行队列中元素的排序。

　　getDelay(TimeUnit unit):这个方法返回到激活日期的剩余时间，时间单位由单位参数指定。

　　下面给出一个简单的案例，网吧与网民上网，网民交了钱后开始上网，当上网时间到了，网吧结束网民上网。

/**
 * 网民实体类
 */
public class Netizen implements Delayed {
    
    //身份证
    private Long id;
    //姓名
    private String name;
    //上网截至时间
    private Long endTime;
    //定义时间工具类
    private TimeUnit timeUnit = TimeUnit.SECONDS;
    
    public Netizen(Long id, String name, Long endTime) {
        super();
        this.id = id;
        this.name = name;
        this.endTime = endTime;
    }
    public Long getId() {
        return id;
    }
    public void setId(Long id) {
        this.id = id;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    public Long getEndTime() {
        return endTime;
    }
    public void setEndTime(Long endTime) {
        this.endTime = endTime;
    }
    //元素相互批较排序
    public int compareTo(Delayed o) {
        Netizen netizen=(Netizen) o;
        return this.getDelay(this.timeUnit)-netizen.getDelay(this.timeUnit)>0?1:0;
    }
    //判断是否到了截至时间
    public long getDelay(TimeUnit unit) {
        
        return endTime-System.currentTimeMillis();
    }
}

/**
 * 网吧实体类
 * @author szekinwin
 *
 */
public class InternetBar implements Runnable{
    
    private DelayQueue<Netizen> queue=new DelayQueue<Netizen>();
    
    //网民上网
    public void startComputer(Long id,String name,int money){
        
        Netizen netizen=new Netizen(id, name, 1000*money+System.currentTimeMillis());
        
        System.out.println("网名"+name+"开始上网计费...");
        
        queue.add(netizen);
        
    }
    //网民上网时间结束
    public void overComputer(Netizen netizen){
        
        System.out.println("网名"+netizen.getName()+"上网时间结束...");
        
    }
　　//检查上网时间是否到期
    public void run() {
        
        while(true){
            try {
                Netizen netizen=queue.take();
                overComputer(netizen);
            } 
            catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
    
    public static void main(String[]args){
        InternetBar internatBar=new InternetBar();
　　　　　//创建三个网民
        internatBar.startComputer(1L, "n1", 3);
        internatBar.startComputer(2L, "n2", 5);
        internatBar.startComputer(3L, "n3", 7);
        Thread t1=new Thread(internatBar);
        t1.start();
    }
}

　　输出结果如下：

　　

　　接下来总结一下PriorityBlockingQueue优先级队列，存放在队列中的元素必须实现Comparable接口，重写compareTo（）方法。

public class Task implements Comparable<Task>{

    private int id;
    
    private String name;
    
    public int getId() {
        return id;
    }

    public void setId(int id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public int compareTo(Task o) {
        return this.id > o.id?1:(this.id < o.id?-1:0);
    }
    
    public String toString(){
        return this.id + "," + this.name;
    }

}

public class PriorityQueueDemo {
    
    public static void main(String[]args) throws InterruptedException{
        
        PriorityBlockingQueue<Task> queue=new PriorityBlockingQueue<Task>();
        Task t1=new Task();
        t1.setId(5);
        t1.setName("p1");
        Task t2=new Task();
        t2.setId(3);
        t2.setName("p2");
        Task t3=new Task();
        t3.setId(7);
        t3.setName("p3");
        queue.add(t1);
        queue.add(t2);
        queue.add(t3);
        System.out.println(queue.toString());
        System.out.println(queue.take().getId());
    }
}

　　输出结果如下：也就是说队列中的元素是根据元素的ID进行排序的。ID值低的优先级高。

　　

　　参考网址:http://www.cnblogs.com/wxgblogs/p/5464867.html