阻塞任务队列DelayQueue

DelayQueue也和其他阻塞队列一样，采用put和take进行存储。但有意思的是，这个队列里面所存储的对象都带有一个时间参数，采用take获取数据的时候，如果时间没有到，取不出来任何数据。而加入数据的时候，是不会阻塞的。


一般用在清理超时对象的场景：

比如，有一批对象，用完后存入(offer)这个队列，并设定60秒delay(超时)， 然后有个线程在外面拼命的take，如果有任何对象被take出来，就清理。只有那些被限制超过60秒的，才会被take.

除此之外，DelayQueue中的对象，还可以通过iterator进行访问，因此，它非常适合用在以下这种场景： 当我们有一组资源，每个资源都有自己的超时策略，我们每次使用资源的时候，都需要用到所有未超时的资源。（比如，server push中的client session）通过把这组资源放入DelayQueue，然后开个Thread不断take，能take出资源，就清理。需要注意的是iterator方法，和clean的方法需要块同步一下。

public class DeplayQueueTest {

	public static void main(String args[]){
		DelayQueue queue=new DelayQueue();
		for(int i=0;i<20;i++){
			long delay=(long)(Math.random()*20000);
			queue.offer(new DelayTask(delay,queue,i));
		}
		Executors.newCachedThreadPool().execute(new Consumer(queue));
	}
}
class Consumer implements Runnable{
	DelayQueue q;
	public Consumer(DelayQueue _q){
		q=_q;
	}
	
	public void run() {
		while(true){
			try {
				System.out.println((DelayTask)(q.take()));
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	}
}
class DelayTask implements Delayed{
	private static int count=0;
	private int id=count++;
	private long nanoTime=System.nanoTime();
	private long delayInMilliseconds;
	private long triger;
	private DelayQueue q;
	private int order;
	
	public DelayTask(long _delay,DelayQueue _q,int _order){
		order=_order;
		q=_q;
		this.delayInMilliseconds=_delay;
		triger=nanoTime+TimeUnit.NANOSECONDS.convert(_delay,TimeUnit.MILLISECONDS);
	}
		/* (non-Javadoc)
	 * @see java.util.concurrent.Delayed#getDelay(java.util.concurrent.TimeUnit)
	 */
	public long getDelay(TimeUnit unit) {
		return triger-System.nanoTime();
	}
	/* (non-Javadoc)
	 * @see java.lang.Comparable#compareTo(java.lang.Object)
	 */
	public int compareTo(Object o) {
		DelayTask delayTask=(DelayTask)o;
		return triger>delayTask.triger?1:triger<delayTask.triger?-1:0;
	}
	
	public String toString(){
		return "Task#"+id+" in index "+order+": delaying "+delayInMilliseconds+" miliseconds picked up.";
	}
}