2112A-ONE
/
muyu-quest
6
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: 2112A-ONE:a082b4dbbf0c5c58b37e25f25ed4c0e62a5ff886
Branches Tags
2112A-ONE:master
...
compare: 2112A-ONE:8d1b33f9032be5b7312c9823fca20ac76f736cd4
Branches Tags
2112A-ONE:master

2 Commits
a082b4dbbf ... 8d1b33f903

Author SHA1 Message Date
面包骑士 8d1b33f903 调整每条线程执行条数至10W 2024-09-08 09:19:43 +08:00
面包骑士 75654a54f4 线程池长度修改为8 2024-09-07 20:50:30 +08:00
2 changed files with 4 additions and 3 deletions
Show Stats Expand all files Collapse all files

2
muyu-quest-server/src/main/java/com/muyu/quest/manager/TaskManager.java
View File

@ -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;
// 未处理的任务 // 未处理的任务

5
muyu-quest-server/src/main/java/com/muyu/quest/service/impl/TaskServiceImpl.java
View File

@ -149,12 +149,13 @@ 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);
// 获取查询条数 // 获取查询条数
int count = getFindCount(findSql, nodeMap); int count = getFindCount(findSql, nodeMap);
// 划分线程 每次查询10000条 // 划分线程 每次查询100000条
int pageSize = 10000; int pageSize = 100000;
int threadNum = count / pageSize + 1; int threadNum = count / pageSize + 1;
log.info("任务 {} 总共需要 {} 条数据, 划分为线程{}条",taskCode,count,threadNum); log.info("任务 {} 总共需要 {} 条数据, 划分为线程{}条",taskCode,count,threadNum);
for (int i = 0; i < threadNum; i++) { for (int i = 0; i < threadNum; i++) {