From bf47f0de2c4b4ca35ce08c7abd2b5b2477b31dac Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Thu, 18 Jul 2024 03:20:57 +0800
Subject: [PATCH] 1
---
websocketClient/src/main/java/org/example/ThreadConfig/AsyncConfiguration.java | 10 +++++-----
1 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/websocketClient/src/main/java/org/example/config/AsyncConfiguration.java b/websocketClient/src/main/java/org/example/ThreadConfig/AsyncConfiguration.java
similarity index 72%
rename from websocketClient/src/main/java/org/example/config/AsyncConfiguration.java
rename to websocketClient/src/main/java/org/example/ThreadConfig/AsyncConfiguration.java
index f77bada..bbbc919 100644
--- a/websocketClient/src/main/java/org/example/config/AsyncConfiguration.java
+++ b/websocketClient/src/main/java/org/example/ThreadConfig/AsyncConfiguration.java
@@ -1,4 +1,4 @@
-package org.example.config;
+package org.example.ThreadConfig;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@@ -17,11 +17,11 @@
@Bean(name = "threadPoolTaskExecutor")
public ThreadPoolTaskExecutor threadPoolTaskExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
- executor.setCorePoolSize(50); // 核心线程数
- executor.setMaxPoolSize(100); // 最大线程数
- executor.setQueueCapacity(300); // 队列容量
+ executor.setCorePoolSize(400); // 核心线程数
+ executor.setMaxPoolSize(1200); // 最大线程数
+ executor.setQueueCapacity(1500); // 队列容量
executor.setKeepAliveSeconds(60); // 线程空闲时的存活时间为60秒
- executor.setThreadNamePrefix("MyThread-"); // 线程名称的前缀
+ executor.setThreadNamePrefix("MexcThread-"); // 线程名称的前缀
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); // 使用 CallerRunsPolicy 拒绝策略
return executor;
}
--
Gitblit v1.9.3