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)