使用扫描线程为线程池运行

byit-myth-admin/src/main/java/com/byit/controller/EmailController.java

@@ -22,5 +22,6 @@ public class EmailController {
     @RequestMapping("/threadCodeCount")
     public int getAcCount(){
         return DaemonScanThreadRunHelperRedisLock.SCAN_WORLD_THREAD.getActiveCount();
+        //return 1;
     }
 }

byit-myth-core/myth-admin-core/src/main/java/com/byit/factory/DaemonScanThreadRunHelperRedisLock.java

@@ -25,12 +25,12 @@ public class DaemonScanThreadRunHelperRedisLock extends BaseDaemonScanThreadRunH
     /**
      * 扫描线程数量
      */
-    //public static ThreadPoolExecutor SCAN_WORLD_THREAD = null;
+    public static ThreadPoolExecutor SCAN_WORLD_THREAD = null;
 
     @Override
     public void runDaemonThreads() {
         Set<Map.Entry<String, BaseThreadRunHelper>> entries = THREAD_RUN_OPT.entrySet();
-        //SCAN_WORLD_THREAD = ThreadPoolUtil.createFixedLengthThreadPoolExecutor("scan flow stream thread",entries.size());
+        SCAN_WORLD_THREAD = ThreadPoolUtil.createFixedLengthThreadPoolExecutor("scan flow stream thread",entries.size());
         entries.forEach(threadExamples ->{
             String examplesKey = threadExamples.getKey();
             BaseThreadRunHelper examplesValue = threadExamples.getValue();
@@ -70,8 +70,8 @@ public class DaemonScanThreadRunHelperRedisLock extends BaseDaemonScanThreadRunH
         });
         exampleThread.setName(threadName);
         exampleThread.setDaemon(true);
-        //SCAN_WORLD_THREAD.execute(exampleThread);
-        exampleThread.start();
+        SCAN_WORLD_THREAD.execute(exampleThread);
+        //exampleThread.start();
         THREADS_MAP.put(threadName,exampleThread);
     }
 }