子线程测试

This commit is contained in:
wulin 2020-11-18 18:23:55 +08:00
parent 1bc743ac42
commit 33d7a29f34

View File

@ -836,12 +836,20 @@ public class FlowStartServiceImpl extends ServiceImpl<FlowStartMapper, FlowStart
//String newNo = oldNo + "_initFlowRecord" ;//+ resultRecord.getStaffId() + "_" + resultRecord.getId();
//ch.qos.logback.classic.Logger.threadLocalNo.set(newNo);
log.info("开始批量初始化流程,数量{}", resultRecords.size());
for (ResultRecord resultRecord:resultRecords
for (int i = 0; i < 105; i++){
log.info("批量{}", i);
try {
Thread.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
/*for (ResultRecord resultRecord:resultRecords
) {
resultRecordService.initFlowRecord(resultRecord.getId());
}
}*/
//ch.qos.logback.classic.Logger.threadLocalNo.set(oldNo);
dingtalkBusiness.sendWorkMSGWithAsyn(noticeStaff, WorkMsgTypeEnum.START_WORK.getType());
threadInitFlowRecords.remove(this);