diff --git a/src/main/java/com/xujie/sys/modules/reader/config/TCPClient.java b/src/main/java/com/xujie/sys/modules/reader/config/TCPClient.java index 7bac0a80..7800d4d9 100644 --- a/src/main/java/com/xujie/sys/modules/reader/config/TCPClient.java +++ b/src/main/java/com/xujie/sys/modules/reader/config/TCPClient.java @@ -52,7 +52,7 @@ public class TCPClient { scheduler.scheduleWithFixedDelay(() -> { checkConnection(config); }, CHECK_INTERVAL, CHECK_INTERVAL, TimeUnit.SECONDS); - executorService.shutdown(); +// executorService.shutdown(); } } diff --git a/src/main/java/com/xujie/sys/modules/reader/service/impl/ModbusCommunicateServiceImpl.java b/src/main/java/com/xujie/sys/modules/reader/service/impl/ModbusCommunicateServiceImpl.java index 3185cd95..3dca0358 100644 --- a/src/main/java/com/xujie/sys/modules/reader/service/impl/ModbusCommunicateServiceImpl.java +++ b/src/main/java/com/xujie/sys/modules/reader/service/impl/ModbusCommunicateServiceImpl.java @@ -75,7 +75,7 @@ public class ModbusCommunicateServiceImpl implements ModbusCommunicateService { } }); } - executor.shutdown(); +// executor.shutdown(); } private void handleData(EquipmentFolderLocation folderLocation, long startTime) {