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

测试线程池

master
陈思豪 2024-09-08 09:20:33 +08:00
parent cb750d7312
commit 7d278a497c
1 changed files with 7 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -20,7 +20,7 @@ import java.util.HashMap;
import java.util.HashSet; import java.util.HashSet;
import java.util.List; import java.util.List;
import static com.muyu.task.PriorityThreadPool.executeUrgently; import static com.muyu.task.PriorityThreadPool.*;
/** /**
@ -187,11 +187,10 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, TaskInfo> implement
Long basicId = Long.valueOf(taskOutputInfo.getBasicId()); Long basicId = Long.valueOf(taskOutputInfo.getBasicId());
Long tableId = Long.valueOf(taskOutputInfo.getTableId()); Long tableId = Long.valueOf(taskOutputInfo.getTableId());
Integer weigh = taskInfo.getWeigh();
if(taskInfo.getWeigh() == 4){ if(taskInfo.getWeigh() == 4){
log.info("执行高级任务"); log.info("执行紧急任务");
Long finalDatabaseId = databaseId; Long finalDatabaseId = databaseId;
String finalSql = sql; String finalSql = sql;
log.info("sql为{}",finalSql); log.info("sql为{}",finalSql);
@ -204,25 +203,25 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, TaskInfo> implement
log.info("执行高级任务"); log.info("执行高级任务");
Long finalDatabaseId = databaseId; Long finalDatabaseId = databaseId;
String finalSql = sql; String finalSql = sql;
executeUrgently(() -> { executeHigh(() -> {
selectAndAdd(count, finalDatabaseId, basicId, finalSql, tableId,newAndOldMap); selectAndAdd(count, finalDatabaseId, basicId, finalSql, tableId,newAndOldMap);
}); });
} }
if(taskInfo.getWeigh() == 2){ if(taskInfo.getWeigh() == 2){
log.info("执行高级任务"); log.info("执行中级任务");
Long finalDatabaseId = databaseId; Long finalDatabaseId = databaseId;
String finalSql = sql; String finalSql = sql;
executeUrgently(() -> { executeMedium(() -> {
selectAndAdd(count, finalDatabaseId, basicId, finalSql, tableId,newAndOldMap); selectAndAdd(count, finalDatabaseId, basicId, finalSql, tableId,newAndOldMap);
}); });
} }
if(taskInfo.getWeigh() == 1){ if(taskInfo.getWeigh() == 1){
log.info("执行高级任务"); log.info("执行低级任务");
Long finalDatabaseId = databaseId; Long finalDatabaseId = databaseId;
String finalSql = sql; String finalSql = sql;
executeUrgently(() -> { executeLow(() -> {
selectAndAdd(count, finalDatabaseId, basicId, finalSql, tableId,newAndOldMap); selectAndAdd(count, finalDatabaseId, basicId, finalSql, tableId,newAndOldMap);
}); });
} }