diff --git a/src/main/java/com/lz/modules/flow/service/impl/FlowStartServiceImpl.java b/src/main/java/com/lz/modules/flow/service/impl/FlowStartServiceImpl.java index deaff8e8..09a003ae 100644 --- a/src/main/java/com/lz/modules/flow/service/impl/FlowStartServiceImpl.java +++ b/src/main/java/com/lz/modules/flow/service/impl/FlowStartServiceImpl.java @@ -103,6 +103,8 @@ public class FlowStartServiceImpl extends ServiceImpl threads = new ArrayList<>(); + @@ -807,9 +809,13 @@ public class FlowStartServiceImpl extends ServiceImpl resultRecords){ - ThreadInitFlowRecord threadInitFlowRecord = new ThreadInitFlowRecord(resultRecords); - Thread thread = new Thread(threadInitFlowRecord); - thread.start(); + if(resultRecords.size() > 0){ + ThreadInitFlowRecord threadInitFlowRecord = new ThreadInitFlowRecord(resultRecords); + Thread thread = new Thread(threadInitFlowRecord); + thread.start(); + threads.add(thread); + } + } public class ThreadInitFlowRecord implements Runnable{ @@ -833,6 +839,7 @@ public class FlowStartServiceImpl extends ServiceImpl