From 7ef22b28f20ad5d30534f7fc59e29d86ce222c4e Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Tue, 02 Jul 2024 16:15:08 +0800
Subject: [PATCH] 1
---
websocketClient/src/main/java/org/example/config/AsyncConfiguration.java | 28 ++++++++++++++++++++++++++++
1 files changed, 28 insertions(+), 0 deletions(-)
diff --git a/websocketClient/src/main/java/org/example/config/AsyncConfiguration.java b/websocketClient/src/main/java/org/example/config/AsyncConfiguration.java
new file mode 100644
index 0000000..f77bada
--- /dev/null
+++ b/websocketClient/src/main/java/org/example/config/AsyncConfiguration.java
@@ -0,0 +1,28 @@
+package org.example.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
+
+import java.util.concurrent.ThreadPoolExecutor;
+
+/**
+ * @program: dabaogp
+ * @description:
+ * @create: 2024-06-25 16:37
+ **/
+@Configuration
+public class AsyncConfiguration {
+
+ @Bean(name = "threadPoolTaskExecutor")
+ public ThreadPoolTaskExecutor threadPoolTaskExecutor() {
+ ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
+ executor.setCorePoolSize(50); // 核心线程数
+ executor.setMaxPoolSize(100); // 最大线程数
+ executor.setQueueCapacity(300); // 队列容量
+ executor.setKeepAliveSeconds(60); // 线程空闲时的存活时间为60秒
+ executor.setThreadNamePrefix("MyThread-"); // 线程名称的前缀
+ executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); // 使用 CallerRunsPolicy 拒绝策略
+ return executor;
+ }
+}
--
Gitblit v1.9.3