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 6055980..4d606e5 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 @@ -281,7 +281,7 @@ public class TaskInfoServiceImpl extends ServiceImpl i // 调整线程分配以适应紧急任务 OptimizedPrioritizedThreadPool.activeEmergencyTasks.set(0); OptimizedPrioritizedThreadPool.remainingTasks.set(0); - for (long i = 1; i <= count; i++) { + for (long i = 1; i <= count+1; i++) { long pageNum = (i - 1) * PAGE_SIZE; submitEmergencyTask(()->{ try {