DelayQueue使⽤实例
DelayQueue是延迟阻塞队列。这种特性可以让我们做⼀些ArrayBlockingQueue、LinkedBlockingQueue这种常规阻塞队列所做不到的事情。⽐如说银⾏转账24h后才到账，微信转账2h到账或者24⼩时到账。
public class DelayQueueTest {
public static void main(String[] args) {
DelayQueue<MyTimerRunnable> blockingQueue = new DelayQueue<>();
blockingQueue.put(new MyTimerRunnable(System.currentTimeMillis() + 10 * 1000,
() -> System.out.println(10)));
blockingQueue.put(new MyTimerRunnable(System.currentTimeMillis() + 5 * 1000,
() -> System.out.println(5)));
blockingQueue.put(new MyTimerRunnable(System.currentTimeMillis() + 15 * 1000,
() -> System.out.println(15)));
System.out.println("开始---" + System.currentTimeMillis());
枸杞泡酒比例for (; ; ) {
try {
MyTimerRunnable timerRunnable = blockingQueue.take();
System.out.println("处理---" + System.currentTimeMillis());
Runnable runnable = Runnable();
if (runnable != null) {
runnable.run();
}
} catch (Exception e) {
e.printStackTrace();
}
}
}
}
张开来MyTimerRunnable是我们⾃定义的Delayed接⼝的实现类，⾥⾯定义了⼀些属性，包括执⾏时间以及执⾏的任务。⾃定义类必须实现Delayed接⼝的getDelay()⽅法和Delayed接⼝继承⾃Comoarable接⼝的compareTo()⽅法。
public class MyTimerRunnable implements Delayed {
private long processTime;
private Runnable runnable;
public long getProcessTime() {
return processTime;
}
public Runnable getRunnable() {
return runnable;
骊山烽火}
public MyTimerRunnable(long processTime, Runnable runnable) {
招商城
this.processTime = processTime;
this.runnable = runnable;
车间安全培训
}
@Override
public long getDelay(@NotNull TimeUnit unit) {
return processTime - System.currentTimeMillis();
}
@Override有梦不觉夜漫长
public int compareTo(@NotNull Delayed o) {
drain
return (int) (getProcessTime() - ((MyTimerRunnable) o).getProcessTime());
}
鲁滨逊漂流记有感}
打印结果是
开始---1584076398361
处理---1584076403361
5
处理---1584076408322
10
处理---1584076413361
15
