线程池长度修改为8
parent
a082b4dbbf
commit
75654a54f4
|
@ -23,7 +23,7 @@ import java.util.List;
|
||||||
|
|
||||||
public final class TaskManager {
|
public final class TaskManager {
|
||||||
// 线程池中默认线程的个数为5
|
// 线程池中默认线程的个数为5
|
||||||
private static int workerNum = 5;
|
private static int workerNum = 8;
|
||||||
// 工作线程
|
// 工作线程
|
||||||
private final WorkThread[] workThrads;
|
private final WorkThread[] workThrads;
|
||||||
// 未处理的任务
|
// 未处理的任务
|
||||||
|
|
|
@ -149,6 +149,7 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, Task>
|
||||||
List<Node> nodeListAll = nodeService.selectNodeList(new NodeReq().buildTaskCode(taskCode));
|
List<Node> nodeListAll = nodeService.selectNodeList(new NodeReq().buildTaskCode(taskCode));
|
||||||
// 节点初始化
|
// 节点初始化
|
||||||
HashMap<String, List<Node>> nodeMap = nodeCheckNorm(nodeListAll);
|
HashMap<String, List<Node>> nodeMap = nodeCheckNorm(nodeListAll);
|
||||||
|
|
||||||
// 获取查询SQL
|
// 获取查询SQL
|
||||||
String findSql = getFindSql(nodeMap);
|
String findSql = getFindSql(nodeMap);
|
||||||
// 获取查询条数
|
// 获取查询条数
|
||||||
|
|
Loading…
Reference in New Issue