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 dd4a9fa..bd0d040 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 @@ -324,9 +324,6 @@ public class TaskInfoServiceImpl extends ServiceImpl i String key = dataValue.getKey(); String newKey = map.get(key); dataValue.setKey(newKey); - if (pageNum==160000){ - log.info(dataValue); - } } } log.info("{}查询结束",sqlSelect); diff --git a/cloud-task-server/src/main/java/com/muyu/task/server/thread/OptimizedPrioritizedThreadPool.java b/cloud-task-server/src/main/java/com/muyu/task/server/thread/OptimizedPrioritizedThreadPool.java index 71ec0aa..9c806cb 100644 --- a/cloud-task-server/src/main/java/com/muyu/task/server/thread/OptimizedPrioritizedThreadPool.java +++ b/cloud-task-server/src/main/java/com/muyu/task/server/thread/OptimizedPrioritizedThreadPool.java @@ -62,7 +62,7 @@ public class OptimizedPrioritizedThreadPool { emergencySemaphore.release(); if (remainingTasks.decrementAndGet() == 0) { try { - Thread.sleep(10000); + Thread.sleep(800000); } catch (InterruptedException e) { throw new RuntimeException(e); }