From 813880747a15ce3050ba31c0eaeb482203d465b9 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=B0=91=E5=B9=B4=E6=A2=A6=E4=B8=8E=E7=A0=96?= <2847127106@qq.com> Date: Tue, 10 Sep 2024 10:06:25 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B5=8B=E8=AF=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/muyu/quest/service/impl/TaskServiceImpl.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) 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); // 如果线程池未创建 => 创建, 如果已完成内部任务 => 清理后创建新线程池