|
@@ -26,7 +26,7 @@ public class DeviceServiceImpl implements IDeviceService {
|
|
|
|
|
|
// 用于存储定时任务的Map,key为deviceCode
|
|
|
private final ConcurrentHashMap<String, ScheduledFuture<?>> scheduledTasks = new ConcurrentHashMap<>();
|
|
|
- private final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(10);
|
|
|
+ private final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(5000);
|
|
|
|
|
|
//用于存储正在执行任务的集合
|
|
|
private final ConcurrentSkipListSet<String> openedDevice = new ConcurrentSkipListSet<>();
|
|
@@ -73,7 +73,7 @@ public class DeviceServiceImpl implements IDeviceService {
|
|
|
cancelTask(deviceCode); // 确保任务只执行一次
|
|
|
};
|
|
|
// 延迟60分钟执行
|
|
|
- ScheduledFuture<?> futureNew = scheduler.schedule(task, 2, TimeUnit.MINUTES);
|
|
|
+ ScheduledFuture<?> futureNew = scheduler.schedule(task, 60, TimeUnit.MINUTES);
|
|
|
scheduledTasks.put(deviceCode, futureNew);
|
|
|
}else{
|
|
|
log.debug("{} 设备已开启定时任务!或正在执行工单任务!不开启定时任务",bo.getCode());
|