DelayQueueテスト

DelayQueueは、遅延操作が可能なキューである.「タイミング消費」を設計するためによく使用されるキューです.つまり、queue内のメンバーを「期限切れ」時間でソートする能力が提供され、queueから取得したメンバーはタイムアウトに最も近いに違いありません.さらにDelayQueueは同時対応であり、内部実装は非常に簡単である:ReentrantLock+PriorityQueue;
以下に自己テストクラスを示す.
 

public class DelayQueueTest {
/**
 * @param args
 */
	public static void main(String[] args) {
		DelayQueue<DelayedItem> queue = new DelayQueue<DelayedItem>();
		for(int i = 0; i<5; i++){
			queue.add(new DelayedItem(System.currentTimeMillis() - i * 1000));
		}
		DelayedItem item = null;
		while((item = queue.peek()) != null){
			System.out.println("...." + item.getTime());
			if(item.getDelay(TimeUnit.MILLISECONDS) <= 0){
				queue.poll();
			}
		}
		System.out.println("End,queue size is :" + queue.size());
	}

	public static class DelayedItem implements Delayed{
		private long time;
		DelayedItem(long time){
			this.time = time;
		}
		public long getTime() {
			return time;
		}
		@Override
		public long getDelay(TimeUnit unit) {
			return unit.convert(time - System.currentTimeMillis(),TimeUnit.MILLISECONDS);
		}
		@Override
		public int compareTo(Delayed o) {
			if(o instanceof DelayedItem){
				DelayedItem di = (DelayedItem)o;
				if(time > di.getTime()){
					return 1;
				}else if(time == di.getTime()){
					return 0;
				}else{
					return -1;
				}
			}
			throw new RuntimeException("State Error!");
		}
	}
}