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

寻找报错

master
Cui YongXing 2024-09-07 10:10:32 +08:00
parent 03bd79b686
commit cb9d0107ae
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 emergencySemaphore;
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 totalThreads =10; // 固定线程池大小
private static final int defaultHighThreads = 5;
private static final int defaultMediumThreads = 3;
private static final int defaultLowThreads = 2;
private static final int emergencyThreads = 20;
private static final int emergencyHighThreads = 11;
private static final int emergencyMediumThreads = 7;
private static final int emergencyLowThreads = 2;
private static final int emergencyThreads = 4;
private static final int emergencyHighThreads = 2;
private static final int emergencyMediumThreads = 1;
private static final int emergencyLowThreads = 1;
private static volatile boolean inEmergencyMode = false;
public static final AtomicInteger activeEmergencyTasks = new AtomicInteger(0); // 紧急任务计数器