diff --git a/boot-starter/boot-starter-security/boot-starter-security-demo/src/main/java/com/micro/fast/security/demo/pojo/MockQueue.java b/boot-starter/boot-starter-security/boot-starter-security-demo/src/main/java/com/micro/fast/security/demo/pojo/MockQueue.java index ce75d72..3b2fd45 100644 --- a/boot-starter/boot-starter-security/boot-starter-security-demo/src/main/java/com/micro/fast/security/demo/pojo/MockQueue.java +++ b/boot-starter/boot-starter-security/boot-starter-security-demo/src/main/java/com/micro/fast/security/demo/pojo/MockQueue.java @@ -20,12 +20,13 @@ public class MockQueue { new Thread(()->{ this.placeOrder = placeOrder; System.out.println("开始处理订单"); - this.completeOrder = placeOrder; try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } + this.completeOrder = placeOrder; + System.out.println("结束处理订单"); }).start(); } diff --git a/boot-starter/boot-starter-security/boot-starter-security-demo/src/main/java/com/micro/fast/security/demo/pojo/QueueListener.java b/boot-starter/boot-starter-security/boot-starter-security-demo/src/main/java/com/micro/fast/security/demo/pojo/QueueListener.java index fa9f069..bcfc137 100644 --- a/boot-starter/boot-starter-security/boot-starter-security-demo/src/main/java/com/micro/fast/security/demo/pojo/QueueListener.java +++ b/boot-starter/boot-starter-security/boot-starter-security-demo/src/main/java/com/micro/fast/security/demo/pojo/QueueListener.java @@ -22,6 +22,7 @@ public class QueueListener implements ApplicationListener while(true){ if (StringUtils.isNotBlank(mockQueue.getCompleteOrder())){ deferredResultHolder.getMap().get(mockQueue.getCompleteOrder()).setResult("success"); + mockQueue.setCompleteOrder(null); }else{ try { Thread.sleep(100);