From c18e4a16669a3497e1021135b1adeaa868ea2d67 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: Sat, 7 Sep 2024 09:18:16 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/com/muyu/quest/manager/TaskManager.java     | 2 +-
 .../java/com/muyu/quest/service/impl/TaskServiceImpl.java     | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/muyu-quest-server/src/main/java/com/muyu/quest/manager/TaskManager.java b/muyu-quest-server/src/main/java/com/muyu/quest/manager/TaskManager.java
index 2629a70..a1db9fc 100644
--- a/muyu-quest-server/src/main/java/com/muyu/quest/manager/TaskManager.java
+++ b/muyu-quest-server/src/main/java/com/muyu/quest/manager/TaskManager.java
@@ -35,7 +35,7 @@ public final class TaskManager {
 
     // 创建具有默认线程个数的线程池
     private TaskManager() {
-        this(10);
+        this(5);
     }
 
     // 创建线程池,workerNum为线程池中工作线程的个数
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 c94e953..1a5fd64 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
@@ -153,7 +153,7 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, Task>
         String findSql = getFindSql(nodeMap);
         // 获取查询条数
         int count = getFindCount(findSql, nodeMap);
-        // 划分线程 每次查询1000条
+        // 划分线程 每次查询10000条
         int pageSize = 10000;
         int threadNum = count / pageSize + 1;
         log.info("任务 {} 总共需要 {} 条数据, 划分为线程{}条",taskCode,count,threadNum);
@@ -163,7 +163,7 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, Task>
             taskManager.execute(() -> {
                 String exportCode = UUID.randomUUID().toString().replace("-","");
                 // 获取新SQL 并执行
-                String sql = findSql + " LIMIT 1000 OFFSET "+(index-1)*pageSize;
+                String sql = findSql + " LIMIT "+pageSize+" OFFSET "+(index-1)*pageSize;
                 String addSql = getAddSql(nodeMap, sql);
                 int addSqlMaxLength = Math.min(addSql.length(), 30000);
                 TaskExport entity = new TaskExport(taskCode,exportCode, addSql.substring(0,addSqlMaxLength), 0, "");