etl
/
cloud-etl-task
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

寻找报错

master
Cui YongXing 2024-09-06 17:25:03 +08:00
parent e8cf98d9d8
commit 6802824f21
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
cloud-task-server/src/main/java/com/muyu/task/server/thread/OptimizedPrioritizedThreadPool.java
View File

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