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 18:27:36 +08:00
parent 33d7a29f34
commit a3ef1860d4
1 changed files with 9 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -106,8 +106,6 @@ public class FlowStartServiceImpl extends ServiceImpl<FlowStartMapper, FlowStart
List<ThreadInitFlowRecord> threadInitFlowRecords = new ArrayList<>(); List<ThreadInitFlowRecord> threadInitFlowRecords = new ArrayList<>();
ThreadInitFlowRecord threadInitFlowRecord;
Thread thread;
@ -812,9 +810,9 @@ public class FlowStartServiceImpl extends ServiceImpl<FlowStartMapper, FlowStart
private void initFlowRecordAnsy(List<ResultRecord> resultRecords, List<StaffSimpleInfo> noticeStaff){ private void initFlowRecordAnsy(List<ResultRecord> resultRecords, List<StaffSimpleInfo> noticeStaff){
if(resultRecords.size() > 0){ if(resultRecords.size() > 0){
threadInitFlowRecord = new ThreadInitFlowRecord(resultRecords, noticeStaff); ThreadInitFlowRecord threadInitFlowRecord = new ThreadInitFlowRecord(resultRecords, noticeStaff);
threadInitFlowRecords.add(threadInitFlowRecord);//防止提前回收 threadInitFlowRecords.add(threadInitFlowRecord);
thread = new Thread(threadInitFlowRecord); Thread thread = new Thread(threadInitFlowRecord);
thread.start(); thread.start();
} }
@ -822,12 +820,12 @@ public class FlowStartServiceImpl extends ServiceImpl<FlowStartMapper, FlowStart
} }
public class ThreadInitFlowRecord implements Runnable{ public class ThreadInitFlowRecord implements Runnable{
List<ResultRecord> resultRecords; List<ResultRecord> resultRecords = new ArrayList<>();
List<StaffSimpleInfo> noticeStaff; List<StaffSimpleInfo> noticeStaff = new ArrayList<>();
public ThreadInitFlowRecord(List<ResultRecord> resultRecords, List<StaffSimpleInfo> noticeStaff){ public ThreadInitFlowRecord(List<ResultRecord> resultRecords, List<StaffSimpleInfo> noticeStaff){
this.resultRecords = resultRecords; this.resultRecords.addAll(resultRecords);
this.noticeStaff = noticeStaff; this.noticeStaff.addAll(noticeStaff);
} }
@Override @Override
@ -836,20 +834,12 @@ public class FlowStartServiceImpl extends ServiceImpl<FlowStartMapper, FlowStart
//String newNo = oldNo + "_initFlowRecord" ;//+ resultRecord.getStaffId() + "_" + resultRecord.getId(); //String newNo = oldNo + "_initFlowRecord" ;//+ resultRecord.getStaffId() + "_" + resultRecord.getId();
//ch.qos.logback.classic.Logger.threadLocalNo.set(newNo); //ch.qos.logback.classic.Logger.threadLocalNo.set(newNo);
log.info("开始批量初始化流程，数量{}", resultRecords.size()); log.info("开始批量初始化流程，数量{}", resultRecords.size());
for (int i = 0; i < 105; i++){ for (ResultRecord resultRecord:resultRecords
log.info("批量{}", i);
try {
Thread.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
/*for (ResultRecord resultRecord:resultRecords
) { ) {
resultRecordService.initFlowRecord(resultRecord.getId()); resultRecordService.initFlowRecord(resultRecord.getId());
}*/ }
//ch.qos.logback.classic.Logger.threadLocalNo.set(oldNo); //ch.qos.logback.classic.Logger.threadLocalNo.set(oldNo);
dingtalkBusiness.sendWorkMSGWithAsyn(noticeStaff, WorkMsgTypeEnum.START_WORK.getType()); dingtalkBusiness.sendWorkMSGWithAsyn(noticeStaff, WorkMsgTypeEnum.START_WORK.getType());
threadInitFlowRecords.remove(this); threadInitFlowRecords.remove(this);