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 c9a6787..7cdf1be 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 @@ -32,7 +32,7 @@ public class OptimizedPrioritizedThreadPool { // 创建固定大小的线程池 executor = new ThreadPoolExecutor( totalThreads, totalThreads, - 60L, TimeUnit.SECONDS, + 120L, TimeUnit.SECONDS, new LinkedBlockingQueue() // 使用无界的阻塞队列 ); highPrioritySemaphore = new Semaphore(defaultHighThreads);