From 5b5e4caf6a4fb87db5044ff3cb0552197f9b9380 Mon Sep 17 00:00:00 2001
From: wulin <wulin@linzikg.com>
Date: Wed, 18 Nov 2020 14:42:01 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B5=8B=E8=AF=95=E5=AD=90=E7=BA=BF=E7=A8=8B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../flow/service/impl/FlowStartServiceImpl.java     | 13 ++++++++++---
 1 file changed, 10 insertions(+), 3 deletions(-)

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<FlowStartMapper, FlowStart
 	@Autowired
 	private DingtalkBusiness dingtalkBusiness;
 
+	List<Thread> threads = new ArrayList<>();
+
 
 
 
@@ -807,9 +809,13 @@ public class FlowStartServiceImpl extends ServiceImpl<FlowStartMapper, FlowStart
 	}
 
 	private void initFlowRecordAnsy(List<ResultRecord> 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<FlowStartMapper, FlowStart
 
 			}
 			ch.qos.logback.classic.Logger.threadLocalNo.set(oldNo);
+			//threads.remove(this);
 		}
 	}
 }