diff --git a/src/main/java/com/wflow/config/AsyncTaskTheadPoolConfig.java b/src/main/java/com/wflow/config/AsyncTaskTheadPoolConfig.java index f51c9e8..fa21ca9 100644 --- a/src/main/java/com/wflow/config/AsyncTaskTheadPoolConfig.java +++ b/src/main/java/com/wflow/config/AsyncTaskTheadPoolConfig.java @@ -65,7 +65,7 @@ public class AsyncTaskTheadPoolConfig { return threadPoolTaskScheduler; } - @Bean + @Bean(name = "wflowThreadPool") public ExecutorService getExecutorService(ThreadPoolTaskExecutor executor){ return Executors.newCachedThreadPool(executor); } diff --git a/src/main/java/com/wflow/workflow/UELTools.java b/src/main/java/com/wflow/workflow/UELTools.java index 9095064..d7a1aa0 100644 --- a/src/main/java/com/wflow/workflow/UELTools.java +++ b/src/main/java/com/wflow/workflow/UELTools.java @@ -28,6 +28,7 @@ import org.flowable.engine.runtime.ProcessInstance; import org.flowable.engine.task.Comment; import org.flowable.task.api.history.HistoricTaskInstance; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.stereotype.Component; import java.time.LocalDateTime; @@ -48,6 +49,7 @@ public class UELTools { private UserDeptOrLeaderService userDeptOrLeaderService; @Autowired + @Qualifier("wflowThreadPool") private ExecutorService executorService; @Autowired diff --git a/src/main/java/com/wflow/workflow/execute/ListenerExecutor.java b/src/main/java/com/wflow/workflow/execute/ListenerExecutor.java index 725dd9e..9df206d 100644 --- a/src/main/java/com/wflow/workflow/execute/ListenerExecutor.java +++ b/src/main/java/com/wflow/workflow/execute/ListenerExecutor.java @@ -18,6 +18,7 @@ import com.wflow.workflow.config.WflowGlobalVarDef; import lombok.extern.slf4j.Slf4j; import org.flowable.engine.RuntimeService; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.stereotype.Component; import java.util.HashSet; @@ -41,6 +42,7 @@ public class ListenerExecutor { private UELTools uelTools; @Autowired + @Qualifier("wflowThreadPool") private ExecutorService executorService; public Object doProcessChangeHandler(String event, String instanceId, String defId){