chenbiao преди 1 година
родител
ревизия
8390497069
променени са 1 файла, в които са добавени 4 реда и са изтрити 4 реда
  1. 4 4
      netflix-common/src/main/java/com/cyksj/common/task/GlobalThreadPoolTaskExecutor.java

+ 4 - 4
netflix-common/src/main/java/com/cyksj/common/task/GlobalThreadPoolTaskExecutor.java

@@ -30,11 +30,11 @@ public final class GlobalThreadPoolTaskExecutor {
 
 	static {
 		// 队列深度.
-		POOLTASKEXECUTOR.setQueueCapacity(Integer.MAX_VALUE);
+		POOLTASKEXECUTOR.setQueueCapacity(1024);
 		// 核心线程数.
-		POOLTASKEXECUTOR.setCorePoolSize(CORE_SIZE * 4);
+		POOLTASKEXECUTOR.setCorePoolSize(CORE_SIZE * 2);
 		// 最大线程数.
-		POOLTASKEXECUTOR.setMaxPoolSize(CORE_SIZE * 4);
+		POOLTASKEXECUTOR.setMaxPoolSize(CORE_SIZE * 2);
 		// 线程名前缀.
 		POOLTASKEXECUTOR.setThreadNamePrefix("DISPATCH_TASK_");
 		// discard
@@ -43,7 +43,7 @@ public final class GlobalThreadPoolTaskExecutor {
 		POOLTASKEXECUTOR.initialize();
 		POOLTASKEXECUTOR.getThreadPoolExecutor().prestartAllCoreThreads();
 		
-		LOGGER.info("线程池启动成功,CPU数: " + CORE_SIZE + ", 核心线程数: " + CORE_SIZE * 4);
+		LOGGER.info("线程池启动成功,CPU数: " + CORE_SIZE + ", 核心线程数: " + CORE_SIZE * 2);
 	}
 
 	private static final GlobalThreadPoolTaskExecutor INSTANCE = new GlobalThreadPoolTaskExecutor();