From 9d982c4ae364270198ed9218c5b2bc5da705fd5f Mon Sep 17 00:00:00 2001
From: wulin <wulin@linzikg.com>
Date: Wed, 18 Nov 2020 18:36:45 +0800
Subject: [PATCH] zi

---
 .../modules/flow/service/impl/FlowStartServiceImpl.java   | 8 ++++----
 1 file changed, 4 insertions(+), 4 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 ed91db23..690438fe 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,7 +103,6 @@ public class FlowStartServiceImpl extends ServiceImpl<FlowStartMapper, FlowStart
 	@Autowired
 	private DingtalkBusiness dingtalkBusiness;
 
-	List<ThreadInitFlowRecord> threadInitFlowRecords = new ArrayList<>();
 
 
 
@@ -811,7 +810,7 @@ public class FlowStartServiceImpl extends ServiceImpl<FlowStartMapper, FlowStart
 	private void initFlowRecordAnsy(List<ResultRecord> resultRecords, List<StaffSimpleInfo> noticeStaff){
 		if(resultRecords.size() > 0){
 			ThreadInitFlowRecord threadInitFlowRecord = new ThreadInitFlowRecord(resultRecords, noticeStaff);
-			threadInitFlowRecords.add(threadInitFlowRecord);
+
 			Thread thread = new Thread(threadInitFlowRecord);
 			thread.start();
 
@@ -824,7 +823,9 @@ public class FlowStartServiceImpl extends ServiceImpl<FlowStartMapper, FlowStart
 		List<StaffSimpleInfo> noticeStaff = new ArrayList<>();
 
 		public ThreadInitFlowRecord(List<ResultRecord> resultRecords, List<StaffSimpleInfo> noticeStaff){
-			this.resultRecords.addAll(resultRecords);
+			CollectionUtils.addAll(this.resultRecords, new Object[resultRecords.size()]);
+			Collections.copy(resultRecords, resultRecords);
+			//this.resultRecords.addAll(resultRecords);
 			this.noticeStaff.addAll(noticeStaff);
 		}
 
@@ -842,7 +843,6 @@ public class FlowStartServiceImpl extends ServiceImpl<FlowStartMapper, FlowStart
 			}
 			//ch.qos.logback.classic.Logger.threadLocalNo.set(oldNo);
 			dingtalkBusiness.sendWorkMSGWithAsyn(noticeStaff, WorkMsgTypeEnum.START_WORK.getType());
-			threadInitFlowRecords.remove(this);
 		}
 	}
 }