后置回调改为异步

byit-myth-core/myth-admin-core/src/main/java/com/byit/conf/RunRecordingThreadPool.java

+package com.byit.conf;
+
+import com.byit.util.ThreadPoolUtil;
+
+import java.util.concurrent.ThreadPoolExecutor;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * @author Administrator
+ */
+public class RunRecordingThreadPool {
+    /**
+     * 实例执行生命周期后置回调的线程
+     */
+    public static ThreadPoolExecutor RUN_RECORDING_THREAD_POOL = ThreadPoolUtil.createCutomizeThreadPoolExecutor("RunRecordingThreadPool",Runtime.getRuntime().availableProcessors()*2,100,60, TimeUnit.SECONDS,1024);
+
+
+}

byit-myth-core/myth-admin-core/src/main/java/com/byit/service/mapservice/impl/RunRecordingAndLogServiceImpl.java

 package com.byit.service.mapservice.impl;
 
 import cn.hutool.core.collection.CollectionUtil;
+import com.byit.conf.RunRecordingThreadPool;
 import com.byit.dto.RunRecordingWrapped;
 import com.byit.enums.EmailEnum;
 import com.byit.enums.FlowPropertyEnum;
@@ -151,13 +152,18 @@ public class RunRecordingAndLogServiceImpl implements RunRecordingAndLogService,
                 runRecordingService.updateRunRecordingById(virtualRunRecording);
             }
 
-            Map<String, InstanceRunTheLifeCycleCallback> beansOfType = SpringUtil.getBeansOfType(InstanceRunTheLifeCycleCallback.class);
-            Set<Map.Entry<String, InstanceRunTheLifeCycleCallback>> entries = beansOfType.entrySet();
-            //回调生命周期
-            for (Map.Entry<String, InstanceRunTheLifeCycleCallback> entry : entries) {
-                log.info("-------------【开始回调周期{}后置】---------------",entry.getKey());
-                entry.getValue().postProcessBeforeInitialization(runRecording);
-            }
+
+            RunRecordingThreadPool.RUN_RECORDING_THREAD_POOL.submit(() ->{
+                Map<String, InstanceRunTheLifeCycleCallback> beansOfType = SpringUtil.getBeansOfType(InstanceRunTheLifeCycleCallback.class);
+                Set<Map.Entry<String, InstanceRunTheLifeCycleCallback>> entries = beansOfType.entrySet();
+                //回调生命周期
+                for (Map.Entry<String, InstanceRunTheLifeCycleCallback> entry : entries) {
+                    log.info("-------------【开始回调周期{}后置】---------------",entry.getKey());
+                    entry.getValue().postProcessBeforeInitialization(runRecording);
+                }
+            });
+
+
 
         });
 

byit-myth-core/myth-admin-core/src/main/java/com/byit/thread/helper/ClosingExampleThreadRunHelper.java

 package com.byit.thread.helper;
 
+import com.byit.conf.RunRecordingThreadPool;
 import com.byit.enums.EmailEnum;
 import com.byit.enums.NodeRunStatusPropertyEnum;
 import com.byit.enums.RunRecordingEnum;
@@ -77,13 +78,18 @@ public class ClosingExampleThreadRunHelper extends BaseThreadRunHelper implement
                 runRecording.setEndTime(new Date());
                 runRecordingService.updateRunRecordingById(runRecording);
                 applicationEventPublisher.publishEvent(new EndFlowEvent(this,runRecording));
-                Map<String, InstanceRunTheLifeCycleCallback> beansOfType = SpringUtil.getBeansOfType(InstanceRunTheLifeCycleCallback.class);
-                Set<Map.Entry<String, InstanceRunTheLifeCycleCallback>> entries = beansOfType.entrySet();
-                //回调生命周期
-                for (Map.Entry<String, InstanceRunTheLifeCycleCallback> entry : entries) {
-                    log.info("-------------【开始回调周期{}后置】---------------",entry.getKey());
-                    entry.getValue().postProcessBeforeInitialization(runRecording);
-                }
+
+                RunRecordingThreadPool.RUN_RECORDING_THREAD_POOL.submit(() ->{
+                    Map<String, InstanceRunTheLifeCycleCallback> beansOfType = SpringUtil.getBeansOfType(InstanceRunTheLifeCycleCallback.class);
+                    Set<Map.Entry<String, InstanceRunTheLifeCycleCallback>> entries = beansOfType.entrySet();
+                    //回调生命周期
+                    for (Map.Entry<String, InstanceRunTheLifeCycleCallback> entry : entries) {
+                        log.info("-------------【开始回调周期{}后置】---------------",entry.getKey());
+                        entry.getValue().postProcessBeforeInitialization(runRecording);
+                    }
+                });
+
+
             }
         });
         return UNIVERSAL_WAIT_TIME;

byit-myth-core/myth-admin-core/src/main/java/com/byit/util/ThreadPoolUtil.java

@@ -70,6 +70,6 @@ public class ThreadPoolUtil {
         ThreadFactory namedThreadFactory = new ThreadFactoryBuilder().setNameFormat("[byit-myth-job]-"+threadName+"-Thread-%d").build();
         return new ThreadPoolExecutor(coreCount, maxCount,
                 keepAliveTime, timeUnit,
-                new LinkedBlockingQueue<Runnable>(1024), namedThreadFactory,  new ThreadPoolExecutor.AbortPolicy());
+                new LinkedBlockingQueue<Runnable>(queueLength), namedThreadFactory,  new ThreadPoolExecutor.AbortPolicy());
     }
 }