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 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 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 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 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) {