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 b30a730..4b2f6ea 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 @@ -11,15 +11,15 @@ public class OptimizedPrioritizedThreadPool { private static final Semaphore lowPrioritySemaphore; private static final Semaphore emergencySemaphore; - private static final int totalThreads =50; // 固定线程池大小 - private static final int defaultHighThreads = 26; - private static final int defaultMediumThreads = 15; - private static final int defaultLowThreads = 9; + private static final int totalThreads =40; // 固定线程池大小 + private static final int defaultHighThreads = 23; + private static final int defaultMediumThreads = 12; + private static final int defaultLowThreads = 5; - private static final int emergencyThreads = 21; - private static final int emergencyHighThreads = 10; - private static final int emergencyMediumThreads = 6; - private static final int emergencyLowThreads = 3; + private static final int emergencyThreads = 20; + private static final int emergencyHighThreads = 9; + private static final int emergencyMediumThreads = 7; + private static final int emergencyLowThreads = 4; private static volatile boolean inEmergencyMode = false; public static final AtomicInteger activeEmergencyTasks = new AtomicInteger(0); // 紧急任务计数器