diff --git a/cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java b/cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java index baa60ab..5b11da9 100644 --- a/cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java +++ b/cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java @@ -190,7 +190,7 @@ public class TaskServiceImpl extends ServiceImpl implement PriorityBlockingQueue queue = new PriorityBlockingQueue<>(totalSegments); // 创建线程池 - ExecutorService executor = Executors.newFixedThreadPool(10); + ExecutorService executor = Executors.newFixedThreadPool(1); for (int i = 0; i < totalSegments; i++) {