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

测试线程池

master
陈思豪 2024-09-09 01:57:40 +08:00
parent b6ac6354c4
commit cf62bbf47c
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java
View File

@ -199,7 +199,7 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, TaskInfo> implement
log.info("执行紧急任务"); log.info("执行紧急任务");
log.info("sql为{}",finalSql); log.info("sql为{}",finalSql);
executeUrgently(() -> { executeUrgently(() -> {
selectAndAdd(finalDatabaseId, basicId, finalSql, tableId,newAndOldMap, finalFirstArray,two); selectAndAdd(finalDatabaseId, basicId, limitSelect, tableId,newAndOldMap, finalFirstArray,two);
}); });
} }
@ -207,7 +207,7 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, TaskInfo> implement
log.info("执行高级任务"); log.info("执行高级任务");
log.info("sql为{}",finalSql); log.info("sql为{}",finalSql);
executeHigh(() -> { executeHigh(() -> {
selectAndAdd(finalDatabaseId, basicId, finalSql, tableId,newAndOldMap, finalFirstArray,two); selectAndAdd(finalDatabaseId, basicId, limitSelect, tableId,newAndOldMap, finalFirstArray,two);
}); });
} }
@ -215,7 +215,7 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, TaskInfo> implement
log.info("执行中级任务"); log.info("执行中级任务");
log.info("sql为{}",finalSql); log.info("sql为{}",finalSql);
executeMedium(() -> { executeMedium(() -> {
selectAndAdd(finalDatabaseId, basicId, finalSql, tableId,newAndOldMap, finalFirstArray,two); selectAndAdd(finalDatabaseId, basicId, limitSelect, tableId,newAndOldMap, finalFirstArray,two);
}); });
} }
@ -223,7 +223,7 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, TaskInfo> implement
log.info("执行低级任务"); log.info("执行低级任务");
log.info("sql为{}",finalSql); log.info("sql为{}",finalSql);
executeLow(() -> { executeLow(() -> {
selectAndAdd(finalDatabaseId, basicId, finalSql, tableId,newAndOldMap, finalFirstArray,two); selectAndAdd(finalDatabaseId, basicId, limitSelect, tableId,newAndOldMap, finalFirstArray,two);
}); });
} }
} }