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

测试线程池

master
lwj 2024-09-08 02:08:36 +08:00
parent d303b71d3c
commit 928858f1d7
1 changed files with 1 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -6,25 +6,19 @@ import com.muyu.common.core.domain.Result;
import com.muyu.common.core.utils.StringUtils; import com.muyu.common.core.utils.StringUtils;
import com.muyu.domain.*; import com.muyu.domain.*;
import com.muyu.domain.req.TaskInfoReq; import com.muyu.domain.req.TaskInfoReq;
import com.muyu.domain.taskenum.Weight;
import com.muyu.mapper.TaskMapper; import com.muyu.mapper.TaskMapper;
import com.muyu.service.TaskInputService; import com.muyu.service.TaskInputService;
import com.muyu.service.TaskJoinService; import com.muyu.service.TaskJoinService;
import com.muyu.service.TaskOutputService; import com.muyu.service.TaskOutputService;
import com.muyu.service.TaskService; import com.muyu.service.TaskService;
import com.muyu.task.feign.DataValueClient; import com.muyu.task.feign.DataValueClient;
import jakarta.annotation.Resource;
import lombok.extern.log4j.Log4j2; import lombok.extern.log4j.Log4j2;
import org.jetbrains.annotations.NotNull;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import java.util.HashMap; import java.util.HashMap;
import java.util.HashSet; import java.util.HashSet;
import java.util.List; import java.util.List;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.PriorityBlockingQueue;
import static com.muyu.task.PriorityThreadPool.executeUrgently; import static com.muyu.task.PriorityThreadPool.executeUrgently;
@ -250,6 +244,7 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, TaskInfo> implement
} }
String limitSelect = sql + limit; String limitSelect = sql + limit;
log.info("执行查询语句为{}", limitSelect); log.info("执行查询语句为{}", limitSelect);
log.info(databaseId);
Result tableValue = dataValueClient.findTableValue(databaseId, limitSelect); Result tableValue = dataValueClient.findTableValue(databaseId, limitSelect);
log.info("远程调用完毕，idaoyong 调用返回的是{}", tableValue); log.info("远程调用完毕，idaoyong 调用返回的是{}", tableValue);
List<List<DataValue>> data = (List<List<DataValue>>) tableValue.getData(); List<List<DataValue>> data = (List<List<DataValue>>) tableValue.getData();