DelayQueue的使用-编程知识

DelayQueue的使用

具体思路：
在容器初始化的时候就创建出一个延迟队列然后项目启动后随即启动一个线程一直监听这个队列
手动调用接口往队列中添加任务
依赖

一个最简单的web的应用即可

项目文件结构
在这里插入图片描述
第一步：在项目启动的时候就创建出一个延迟队列

@Configuration
public class DelayQueueConfig {@Beanpublic DelayQueue delayQueue() {return new DelayQueue();}
}

第二步：项目启动后开启一个线程去监听这个队列

/*ApplicationRunner的作用--项目启动后就执行run方法*/
@Component
public class BlockingQueueConsumer implements ApplicationRunner {@Autowiredprivate DelayQueue delayQueue;@Overridepublic void run(ApplicationArguments args) {/*开启一个线程 去监听 delayQueue*/new Thread(() -> {while (true) {try {Order order = (Order) delayQueue.take();order.run();} catch (InterruptedException e) {e.printStackTrace();}}}).start();}
}

当然，还需要创建出一个能放进队列的类

public class Order implements Delayed {private String orderNo;private long time;public Order(String orderNo, long time) {this.orderNo = orderNo;this.time = time;}@Override/*getDelay--获取现在还有多久才会被消费*/public long getDelay(TimeUnit unit) {return time - System.currentTimeMillis();}@Override/*决定队列中的顺序，谁在前 谁在后*/public int compareTo(Delayed o) {Order order = (Order) o;return Long.compare(this.time, order.time);}public void run() {System.out.println("订单号：" + orderNo + "已经被消费");}
}

最后，我们可以随时调用接口添加任务

@RestController
@RequestMapping("/blockingQueue")
public class BlockingQueueController {@Autowiredprivate DelayQueue delayQueue;@GetMapping("/test")public String test() {return "success";}@GetMapping("/add")public String add() {Order order = new Order("1", 3000+System.currentTimeMillis());Order order1 = new Order("2", 5000 + System.currentTimeMillis());Order order2 = new Order("3", 1000 + System.currentTimeMillis());delayQueue.put(order);delayQueue.put(order1);delayQueue.put(order2);return "success";}
}

结果
在这里插入图片描述