网站建设技巧亅金手指排名25,ckplayer整合WordPress,24小时妇科免费问医生,个人网站栏目具体思路#xff1a; 在容器初始化的时候就创建出一个 延迟队列 然后项目启动后随即启动一个线程一直监听这个队列 手动调用接口往队列中添加任务 依赖
一个最简单的web的应用即可项目文件结构 第一步#xff1a;在项目启动的时候就创建出一个延迟队列
Configuration
publ…具体思路 在容器初始化的时候就创建出一个 延迟队列 然后项目启动后随即启动一个线程一直监听这个队列 手动调用接口往队列中添加任务 依赖
一个最简单的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, 3000System.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;}
}结果
