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
     
       queue=new DelayQueue
      
       ();        //网民上网    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
     
      {    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
     
       queue=new PriorityBlockingQueue
      
       ();        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