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

寻找报错

master
Cui YongXing 2024-09-06 00:29:05 +08:00
parent efb836ba61
commit f6789b19e6
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 = 25; private static final int defaultHighThreads = 22;
private static final int defaultMediumThreads = 15; private static final int defaultMediumThreads = 12;
private static final int defaultLowThreads = 10; private static final int defaultLowThreads = 6;
private static final int emergencyThreads = 25; private static final int emergencyThreads = 21;
private static final int emergencyHighThreads = 13; private static final int emergencyHighThreads = 10;
private static final int emergencyMediumThreads = 7; private static final int emergencyMediumThreads = 6;
private static final int emergencyLowThreads = 5; private static final int emergencyLowThreads = 3;
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); // 紧急任务计数器