修改线程配置
parent
696f4d3a88
commit
bafbaee6c8
|
@ -158,7 +158,7 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, Task>
|
||||||
// 获取查询条数
|
// 获取查询条数
|
||||||
int count = getFindCount(findSql, nodeMap);
|
int count = getFindCount(findSql, nodeMap);
|
||||||
// 划分线程
|
// 划分线程
|
||||||
int pageSize = 30000;
|
int pageSize = 20000;
|
||||||
int taskNum = 8;
|
int taskNum = 8;
|
||||||
int threadNum = count / pageSize + 1;
|
int threadNum = count / pageSize + 1;
|
||||||
log.info("任务 {} 总共需要 {} 条数据, 划分为线程{}条",taskCode,count,threadNum);
|
log.info("任务 {} 总共需要 {} 条数据, 划分为线程{}条",taskCode,count,threadNum);
|
||||||
|
|
Loading…
Reference in New Issue