Compare commits
2 Commits
a082b4dbbf
...
8d1b33f903
Author | SHA1 | Date |
---|---|---|
|
8d1b33f903 | |
|
75654a54f4 |
|
@ -23,7 +23,7 @@ import java.util.List;
|
|||
|
||||
public final class TaskManager {
|
||||
// 线程池中默认线程的个数为5
|
||||
private static int workerNum = 5;
|
||||
private static int workerNum = 8;
|
||||
// 工作线程
|
||||
private final WorkThread[] workThrads;
|
||||
// 未处理的任务
|
||||
|
|
|
@ -149,12 +149,13 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, Task>
|
|||
List<Node> nodeListAll = nodeService.selectNodeList(new NodeReq().buildTaskCode(taskCode));
|
||||
// 节点初始化
|
||||
HashMap<String, List<Node>> nodeMap = nodeCheckNorm(nodeListAll);
|
||||
|
||||
// 获取查询SQL
|
||||
String findSql = getFindSql(nodeMap);
|
||||
// 获取查询条数
|
||||
int count = getFindCount(findSql, nodeMap);
|
||||
// 划分线程 每次查询10000条
|
||||
int pageSize = 10000;
|
||||
// 划分线程 每次查询100000条
|
||||
int pageSize = 100000;
|
||||
int threadNum = count / pageSize + 1;
|
||||
log.info("任务 {} 总共需要 {} 条数据, 划分为线程{}条",taskCode,count,threadNum);
|
||||
for (int i = 0; i < threadNum; i++) {
|
||||
|
|
Loading…
Reference in New Issue