调整每条线程执行条数至10W

master
面包骑士 2024-09-08 09:19:43 +08:00
parent 75654a54f4
commit 8d1b33f903
1 changed files with 2 additions and 2 deletions

View File

@ -154,8 +154,8 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, Task>
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++) {