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 a860c972..d9917be0 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,8 +103,7 @@ public class FlowStartServiceImpl extends ServiceImpl<FlowStartMapper, FlowStart
 	@Autowired
 	private DingtalkBusiness dingtalkBusiness;
 
-	ThreadInitFlowRecord threadInitFlowRecord;// = new ThreadInitFlowRecord(resultRecords, noticeStaff);
-	Thread thread;
+	List<ThreadInitFlowRecord> threads = new ArrayList<>();
 
 
 
@@ -811,9 +810,10 @@ public class FlowStartServiceImpl extends ServiceImpl<FlowStartMapper, FlowStart
 
 	private void initFlowRecordAnsy(List<ResultRecord> resultRecords, List<StaffSimpleInfo> noticeStaff){
 		if(resultRecords.size() > 0){
-			threadInitFlowRecord = new ThreadInitFlowRecord(resultRecords, noticeStaff);
-			thread = new Thread(threadInitFlowRecord);
+			ThreadInitFlowRecord threadInitFlowRecord = new ThreadInitFlowRecord(resultRecords, noticeStaff);
+			Thread thread = new Thread(threadInitFlowRecord);
 			thread.start();
+			threads.add(threadInitFlowRecord);
 		}
 
 	}
@@ -841,7 +841,7 @@ public class FlowStartServiceImpl extends ServiceImpl<FlowStartMapper, FlowStart
 			}
 			//ch.qos.logback.classic.Logger.threadLocalNo.set(oldNo);
 			dingtalkBusiness.sendWorkMSGWithAsyn(noticeStaff, WorkMsgTypeEnum.START_WORK.getType());
-			//threads.remove(this);
+			threads.remove(this);
 		}
 	}
 }