diff --git a/src/main/java/com/dispose/service/impl/DisposeAbilityRouterServiceImpl.java b/src/main/java/com/dispose/service/impl/DisposeAbilityRouterServiceImpl.java index e41b000a..4d328a1d 100644 --- a/src/main/java/com/dispose/service/impl/DisposeAbilityRouterServiceImpl.java +++ b/src/main/java/com/dispose/service/impl/DisposeAbilityRouterServiceImpl.java @@ -197,11 +197,13 @@ public class DisposeAbilityRouterServiceImpl implements DisposeAbilityRouterServ @Async("deviceTaskExecutor") @Scheduled(fixedDelay = 1000) public void runPeriodTask() { - getAllAbilityDevices().forEach(v -> { - v.getDb().periodTaskRuntime(); - // 同步最新处置平台业务信息到设备 - v.getDb().upgradeServiceGroup(serviceGroupMapper.selectAll()); - }); + synchronized (this) { + getAllAbilityDevices().forEach(v -> { + v.getDb().periodTaskRuntime(); + // 同步最新处置平台业务信息到设备 + v.getDb().upgradeServiceGroup(serviceGroupMapper.selectAll()); + }); + } } /**