@@ -34,7 +34,7 @@ import java.util.concurrent.Executors;
public class ActivityDelayJob implements DelayService<DelayActivity> {
/**
- * 预约订单队列
+ * 活动队列
*/
private final static DelayQueue<DelayedItem<DelayActivity>> DELAY_QUEUE = new DelayQueue<>();
@@ -75,6 +75,8 @@ public class StartChargeDelayJob implements DelayService<DelayChargeOrder> {
DelayedItem<DelayChargeOrder> delayedItem;
while (true) {
try {
+ // 线程休眠100ms
+ Thread.sleep(100);
delayedItem = START_DELAY_QUEUE.take();
// 启动充电
var order = delayedItem.data;
@@ -78,6 +78,7 @@ public class StopChargeDelayJob implements DelayService<DelayChargeOrder> {
+ Thread.sleep(200);
delayedItem = STOP_DELAY_QUEUE.take();
// 停止充电