diff --git a/muyu-quest-server/src/main/java/com/muyu/quest/service/impl/TaskServiceImpl.java b/muyu-quest-server/src/main/java/com/muyu/quest/service/impl/TaskServiceImpl.java index bf6ae53..db8351f 100644 --- a/muyu-quest-server/src/main/java/com/muyu/quest/service/impl/TaskServiceImpl.java +++ b/muyu-quest-server/src/main/java/com/muyu/quest/service/impl/TaskServiceImpl.java @@ -161,12 +161,12 @@ public class TaskServiceImpl extends ServiceImpl // 总条数 最大线程数/分配条数 >100W 5/100000 >10W 8/10000 <10W 8/1000 int pageSize = 10000; int taskNum = 8; - if (count > 8000000){ - pageSize = 100000; - taskNum = 5; - }else if (count < 100000){ - pageSize = 1000; - } +// if (count > 8000000){ +// pageSize = 100000; +// taskNum = 5; +// }else if (count < 100000){ +// pageSize = 1000; +// } int threadNum = count / pageSize + 1; log.info("任务 {} 总共需要 {} 条数据, 划分为线程{}条",taskCode,count,threadNum); // 如果线程池未创建 => 创建, 如果已完成内部任务 => 清理后创建新线程池