From 2e3bbf7bbb40f29fa96b5b359dd1632685a1f5df Mon Sep 17 00:00:00 2001 From: "USER-20220102CG\\noblelift" <546428999@qq.com> Date: Sat, 13 Jul 2024 11:19:48 +0800 Subject: [PATCH] =?UTF-8?q?rev=20=E6=9B=B4=E6=96=B0=E8=AE=BE=E5=A4=87?= =?UTF-8?q?=E5=90=8C=E6=AD=A5=E9=BB=98=E8=AE=A4=E6=9C=80=E5=A4=A7=E7=BA=BF?= =?UTF-8?q?=E7=A8=8B=E6=95=B0=EF=BC=8C=E6=8C=89=E7=85=A7PLC=20ip=E6=95=B0?= =?UTF-8?q?=E9=85=8D=E7=BD=AE=E7=BA=BF=E7=A8=8B=E6=95=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/org/nl/acs/opc/DeviceOpcSynchronizeAutoRun.java | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceOpcSynchronizeAutoRun.java b/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceOpcSynchronizeAutoRun.java index f9023e4c5..69ee0c4cc 100644 --- a/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceOpcSynchronizeAutoRun.java +++ b/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceOpcSynchronizeAutoRun.java @@ -31,8 +31,8 @@ public class DeviceOpcSynchronizeAutoRun extends AbstractAutoRunnable { ExecutorService executorService = ThreadPoolBuilder.newBuilder() .threadPoolName("deviceOpc_thread") .threadFactory("deviceOpc_thread") - .corePoolSize(2) - .maximumPoolSize(7) + .corePoolSize(80) + .maximumPoolSize(100) .keepAliveTime(40) .timeUnit(TimeUnit.SECONDS) .workQueue(MEMORY_SAFE_LINKED_BLOCKING_QUEUE.getName(), 2000) @@ -56,6 +56,7 @@ public class DeviceOpcSynchronizeAutoRun extends AbstractAutoRunnable { @Override public void autoRun() throws Exception { { + //Thread.sleep(10000L); isRun = true; Map servers = this.opcServerManageService.queryAllServerMap(); @@ -98,8 +99,8 @@ public class DeviceOpcSynchronizeAutoRun extends AbstractAutoRunnable { this.executorService = ThreadPoolBuilder.newBuilder() .threadPoolName("deviceOpc_thread") .threadFactory("deviceOpc_thread") - .corePoolSize(2) - .maximumPoolSize(7) + .corePoolSize(80) + .maximumPoolSize(100) .keepAliveTime(40) .timeUnit(TimeUnit.SECONDS) .workQueue(MEMORY_SAFE_LINKED_BLOCKING_QUEUE.getName(), 2000)