标签：影响 blocking 延迟 tac 单位 取出 ima 网址 int
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
标签：影响 blocking 延迟 tac 单位 取出 ima 网址 int
原文地址：http://www.cnblogs.com/gdpuzxs/p/6748728.html
