etl
/
cloud-etl-task
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

线程等待

master
Cui YongXing 2024-09-05 19:50:11 +08:00
parent 42da1a6d84
commit 366a3e613e
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskInfoServiceImpl.java
View File

@ -285,6 +285,11 @@ public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> i
getString(pageNum, finalFieName, finalJoint,basicId,newBasicId,tableId,map,num); getString(pageNum, finalFieName, finalJoint,basicId,newBasicId,tableId,map,num);
}); });
} }
try {
Thread.sleep(2000);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
// 任务完成后恢复默认线程分配 // 任务完成后恢复默认线程分配
restoreDefaults(); restoreDefaults();
} }
@ -307,6 +312,7 @@ public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> i
dataValue.setKey(newKey); dataValue.setKey(newKey);
} }
} }
Result result = datasourceFeign.addProduct(newBasicId, tableId, data); Result result = datasourceFeign.addProduct(newBasicId, tableId, data);
log.info(result); log.info(result);
// for (List<DataValue> dataValues : tableValue) { // for (List<DataValue> dataValues : tableValue) {