From 37530d897d718677d35e445bae6372bd4dbd1ad6 Mon Sep 17 00:00:00 2001
From: Cui YongXing <2835316714@qq.com>
Date: Fri, 6 Sep 2024 09:46:30 +0800
Subject: [PATCH] =?UTF-8?q?=E5=AF=BB=E6=89=BE=E6=8A=A5=E9=94=99?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../server/service/impl/TaskInfoServiceImpl.java     | 12 ++++++++----
 1 file changed, 8 insertions(+), 4 deletions(-)

diff --git a/cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskInfoServiceImpl.java b/cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskInfoServiceImpl.java
index cc4f482..8a4b355 100644
--- a/cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskInfoServiceImpl.java
+++ b/cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskInfoServiceImpl.java
@@ -256,8 +256,9 @@ public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> i
                if (pageSize>=PAGE_SIZE){
                    pageSize=PAGE_SIZE;
                }
+                long finalPageSize = pageSize;
                 submitHighPriorityTask(()->{
-                    getString(pageNum, finalFieName, finalJoint,basicId,newBasicId,tableId,map,pageSize,num);
+                    getString(pageNum, finalFieName, finalJoint,basicId,newBasicId,tableId,map, finalPageSize,num);
                 });
 
             }
@@ -270,8 +271,9 @@ public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> i
                 if (pageSize>=PAGE_SIZE){
                     pageSize=PAGE_SIZE;
                 }
+                long finalPageSize1 = pageSize;
                 submitMediumPriorityTask(()->{
-                    getString(pageNum, finalFieName, finalJoint,basicId,newBasicId,tableId,map,pageSize,num);
+                    getString(pageNum, finalFieName, finalJoint,basicId,newBasicId,tableId,map, finalPageSize1,num);
                 });
             }
         }
@@ -283,8 +285,9 @@ public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> i
                 if (pageSize>=PAGE_SIZE){
                     pageSize=PAGE_SIZE;
                 }
+                long finalPageSize2 = pageSize;
                 submitLowPriorityTask(()->{
-                    getString(pageNum, finalFieName, finalJoint,basicId,newBasicId,tableId,map,pageSize,num);
+                    getString(pageNum, finalFieName, finalJoint,basicId,newBasicId,tableId,map, finalPageSize2,num);
                 });
             }
         }
@@ -299,9 +302,10 @@ public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> i
                 if (pageSize>=PAGE_SIZE){
                     pageSize=PAGE_SIZE;
                 }
+                long finalPageSize3 = pageSize;
                 submitEmergencyTask(()->{
                     try {
-                        getString(pageNum, finalFieName, finalJoint, basicId, newBasicId, tableId, map,pageSize, num);
+                        getString(pageNum, finalFieName, finalJoint, basicId, newBasicId, tableId, map, finalPageSize3, num);
                     } finally {
                         // 减少剩余任务计数
                         if (OptimizedPrioritizedThreadPool.remainingTasks.decrementAndGet() == 0) {