同時プログラミング:同時コレクション:遅延要素付きスレッドセキュリティキューDelayQueue

目次
DelayQueue
一、メインプログラム
二、遅延キューの要素クラス
三、キューに要素を追加するクラス
四、実行結果
DelayQueue
DelayQueueはアクティブ化時間を持つ要素を格納し、要素を取得する方法ではアクティブ化時間に達していない要素は無視されます.つまり、これらのアクティブ化時間はまだ将来の要素であり、キューには表示されません.pollメソッドを使用するとnullが返されます.
comparareTo(Delayed o):Comparableインタフェースから継承されます.このメソッドを呼び出すオブジェクトの遅延値がパラメータより小さい場合、メソッドは負の数を返します.大きい、正の数を返します.等しい、ゼロ.
getDelay(TimeUnit unit):メソッドは、現在の時間とアクティブ化時間の差を返します.TimeUnitは時間の単位です.
 
一、メインプログラム

package xyz.jangle.thread.test.n7_5.delayqueue;

import java.util.Date;
import java.util.concurrent.DelayQueue;
import java.util.concurrent.TimeUnit;

/**
 * 7.5、              
 * DelayQueue       Delayed  
 * （Delayed     Comparable  ，         ）
 * 
 * Delayed      ：getDelay        。
 * @author jangle
 * @email [email protected]
 * @time 2020 9 13    8:02:58
 * 
 */
public class M {

	public static void main(String[] args) throws Exception {

		DelayQueue queue = new DelayQueue<>();
		Thread[] threads = new Thread[5];
		for (int i = 0; i < threads.length; i++) {
			var task = new Task(i + 1, queue);
			threads[i] = new Thread(task);
			threads[i].start();
		}
		for (int i = 0; i < threads.length; i++) {
			threads[i].join();
		}
		do {
			int counter = 0;
			Event event;
			do {
				event = queue.poll();
				if (event != null) {
					counter++;
				}
			} while (event != null);
			System.out.println(new Date()+":"+counter+" 。 Size:"+queue.size());
			TimeUnit.MILLISECONDS.sleep(500);
		} while (queue.size() > 0);

	}

}

二、遅延キューの要素クラス

package xyz.jangle.thread.test.n7_5.delayqueue;

import java.util.Date;
import java.util.concurrent.Delayed;
import java.util.concurrent.TimeUnit;

/**
 * 	        
 * @author jangle
 * @email [email protected]
 * @time 2020 9 13    8:03:24
 * 
 */
public class Event implements Delayed {

	private final Date startDate;

	public Event(Date startDate) {
		super();
		this.startDate = startDate;
	}

	@Override
	public int compareTo(Delayed o) {
		long result = this.getDelay(TimeUnit.NANOSECONDS) - o.getDelay(TimeUnit.NANOSECONDS);
		if (result < 0)
			return -1;
		if (result > 0)
			return 1;
		return 0;
	}

	@Override
	public long getDelay(TimeUnit unit) {
		Date now = new Date();
		long diff = startDate.getTime() - now.getTime();
		//         
		return unit.convert(diff,TimeUnit.MICROSECONDS);
	}

}

三、キューに要素を追加するクラス

package xyz.jangle.thread.test.n7_5.delayqueue;

import java.util.Date;
import java.util.concurrent.DelayQueue;

/**
 *            
 * @author jangle
 * @email [email protected]
 * @time 2020 9 13    8:11:22
 * 
 */
public class Task implements Runnable {

	private final int id;

	private final DelayQueue queue;

	public Task(int id, DelayQueue queue) {
		super();
		this.id = id;
		this.queue = queue;
	}

	@Override
	public void run() {
		Date now = new Date();
		Date delay = new Date();
		delay.setTime(now.getTime() + (id * 1000));
		System.out.println("Thread " + id + "," + delay);
		for (int i = 0; i < 100; i++) {
			Event event = new Event(delay);
			queue.add(event);
		}
	}

}

四、実行結果

Thread 4,Sun Sep 13 20:19:49 CST 2020
Thread 2,Sun Sep 13 20:19:47 CST 2020
Thread 3,Sun Sep 13 20:19:48 CST 2020
Thread 1,Sun Sep 13 20:19:46 CST 2020
Thread 5,Sun Sep 13 20:19:50 CST 2020
Sun Sep 13 20:19:45 CST 2020:0 。 Size:500
Sun Sep 13 20:19:45 CST 2020:0 。 Size:500
Sun Sep 13 20:19:46 CST 2020:100 。 Size:400
Sun Sep 13 20:19:46 CST 2020:0 。 Size:400
Sun Sep 13 20:19:47 CST 2020:100 。 Size:300
Sun Sep 13 20:19:47 CST 2020:0 。 Size:300
Sun Sep 13 20:19:48 CST 2020:100 。 Size:200
Sun Sep 13 20:19:48 CST 2020:0 。 Size:200
Sun Sep 13 20:19:49 CST 2020:100 。 Size:100
Sun Sep 13 20:19:49 CST 2020:0 。 Size:100
Sun Sep 13 20:19:50 CST 2020:100 。 Size:0