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 a0481a4..baa60ab 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 @@ -214,8 +214,9 @@ public class TaskServiceImpl extends ServiceImpl implement // 启动线程池执行任务 for (int i = 0; i < 10; i++) { // 可以根据需要调整线程池大小 -// executor.submit(new Worker(queue)); + executor.submit(new Worker(queue)); log.info("运行{}",i); + break; } executor.shutdown();