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

测试

master
面包骑士 2024-09-10 10:06:25 +08:00
parent 7cf44a897e
commit 813880747a
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -161,12 +161,12 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, Task>
// 总条数 最大线程数/分配条数 >100W 5/100000 >10W 8/10000 <10W 8/1000 // 总条数 最大线程数/分配条数 >100W 5/100000 >10W 8/10000 <10W 8/1000
int pageSize = 10000; int pageSize = 10000;
int taskNum = 8; int taskNum = 8;
if (count > 8000000){ // if (count > 8000000){
pageSize = 100000; // pageSize = 100000;
taskNum = 5; // taskNum = 5;
}else if (count < 100000){ // }else if (count < 100000){
pageSize = 1000; // pageSize = 1000;
} // }
int threadNum = count / pageSize + 1; int threadNum = count / pageSize + 1;
log.info("任务 {} 总共需要 {} 条数据, 划分为线程{}条",taskCode,count,threadNum); log.info("任务 {} 总共需要 {} 条数据, 划分为线程{}条",taskCode,count,threadNum);
// 如果线程池未创建 => 创建, 如果已完成内部任务 => 清理后创建新线程池 // 如果线程池未创建 => 创建, 如果已完成内部任务 => 清理后创建新线程池