wulin/wl_management
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

子线程测试

Browse Source
This commit is contained in:
wulin 2020-11-18 15:01:05 +08:00
parent 65a5f94ea2
commit 5b9376d3b7
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/main/java/com/lz/modules/flow/service/impl/FlowStartServiceImpl.java
View File

@ -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);
}
}
}