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 18bc787..dd4a9fa 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 @@ -254,11 +254,7 @@ public class TaskInfoServiceImpl extends ServiceImpl i submitHighPriorityTask(()->{ getString(pageNum, finalFieName, finalJoint,basicId,newBasicId,tableId,map,num); }); - try { - TimeUnit.MILLISECONDS.sleep(100); // 适当延迟,避免所有任务同时提交 - } catch (InterruptedException e) { - Thread.currentThread().interrupt(); - } + } } if (Weight.centre.getValue().equals(weight)){ @@ -312,9 +308,10 @@ public class TaskInfoServiceImpl extends ServiceImpl i String sqlSelect = " SELECT " + fieName + " FROM " + joint +" limit "+pageNum +","+PAGE_SIZE; log.info(sqlSelect); - log.info("执行{}查询的方法",sqlSelect); + //log.info("执行{}查询的方法",sqlSelect); Result tableValueResult = datasourceFeign.findTableValueToArray(basicId, sqlSelect); DataValue[][] data = tableValueResult.getData(); + log.info("执行{}查询的方法结束",sqlSelect); // if (pageNum==160000){ // for (DataValue[] datum : data) { // for (DataValue dataValue : datum) { 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 8fe9775..abecc84 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 @@ -57,9 +57,7 @@ public class OptimizedPrioritizedThreadPool { emergencySemaphore.acquire(); executor.submit(() -> { try { - System.out.println("Starting emergency task..."); task.run(); - System.out.println("Finished emergency task."); } finally { emergencySemaphore.release(); if (remainingTasks.decrementAndGet() == 0) { @@ -69,7 +67,6 @@ public class OptimizedPrioritizedThreadPool { }); } catch (InterruptedException e) { Thread.currentThread().interrupt(); - System.err.println("Interrupted while waiting to execute emergency task."); } } @@ -78,16 +75,13 @@ public class OptimizedPrioritizedThreadPool { highPrioritySemaphore.acquire(); executor.submit(() -> { try { - System.out.println("Starting high priority task..."); task.run(); - System.out.println("Finished high priority task."); } finally { highPrioritySemaphore.release(); } }); } catch (InterruptedException e) { Thread.currentThread().interrupt(); - System.err.println("Interrupted while waiting to execute high priority task."); } } @@ -96,16 +90,13 @@ public class OptimizedPrioritizedThreadPool { mediumPrioritySemaphore.acquire(); executor.submit(() -> { try { - System.out.println("Starting medium priority task..."); task.run(); - System.out.println("Finished medium priority task."); } finally { mediumPrioritySemaphore.release(); } }); } catch (InterruptedException e) { Thread.currentThread().interrupt(); - System.err.println("Interrupted while waiting to execute medium priority task."); } } @@ -114,16 +105,13 @@ public class OptimizedPrioritizedThreadPool { lowPrioritySemaphore.acquire(); executor.submit(() -> { try { - System.out.println("Starting low priority task..."); task.run(); - System.out.println("Finished low priority task."); } finally { lowPrioritySemaphore.release(); } }); } catch (InterruptedException e) { Thread.currentThread().interrupt(); - System.err.println("Interrupted while waiting to execute low priority task."); } }