修改设备站点名称

device-manager/src/main/java/com/mortals/xhx/common/utils/SendTaskThreadPool.java

 package com.mortals.xhx.common.utils;
 
+import org.springframework.core.annotation.Order;
 import org.springframework.stereotype.Component;
 
+import javax.annotation.PostConstruct;
 import java.util.concurrent.Executors;
 import java.util.concurrent.ThreadPoolExecutor;
 
@@ -25,6 +27,11 @@ public class SendTaskThreadPool {
 
     private Object lock = new Object();
 
+    @PostConstruct
+    public void init() {
+        int coreThreadNum = Runtime.getRuntime().availableProcessors();
+        this.init(coreThreadNum * 2);
+    }
 
     public void init(Integer threadNum) {
         if (poolSize < 0) {

device-manager/src/main/java/com/mortals/xhx/daemon/applicationservice/DemoStartService.java

@@ -15,8 +15,8 @@ public class DemoStartService implements IApplicationService {
 
     @Override
     public void start() {
-        int coreThreadNum = Runtime.getRuntime().availableProcessors();
-        sendTaskThreadPool.init(coreThreadNum*2);
+//        int coreThreadNum = Runtime.getRuntime().availableProcessors();
+//        sendTaskThreadPool.init(coreThreadNum*2);
         log.info("开始服务..[配置已加载完成，但部分框架还未初始化，比如：Kafka]");
     }