From 9ed28183ca391eadb7b5cb2f3160e3ec852da124 Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Fri, 11 Oct 2024 23:25:21 +0800
Subject: [PATCH] 1

---
 kucoinClient/src/main/java/org/example/kucoinclient/ThreadConfig/AsyncConfiguration.java   |    6 +++---
 geteClient/src/main/java/org/example/geteclient/ThreadConfig/AsyncConfiguration.java       |    4 ++--
 mexcClient/src/main/java/org/example/mexcclient/ThreadConfig/AsyncConfiguration.java       |    6 +++---
 bitgetsClient/src/main/java/org/example/bitgetsclient/ThreadConfig/AsyncConfiguration.java |    6 +++---
 4 files changed, 11 insertions(+), 11 deletions(-)

diff --git a/bitgetsClient/src/main/java/org/example/bitgetsclient/ThreadConfig/AsyncConfiguration.java b/bitgetsClient/src/main/java/org/example/bitgetsclient/ThreadConfig/AsyncConfiguration.java
index 870633d..cbf41e1 100644
--- a/bitgetsClient/src/main/java/org/example/bitgetsclient/ThreadConfig/AsyncConfiguration.java
+++ b/bitgetsClient/src/main/java/org/example/bitgetsclient/ThreadConfig/AsyncConfiguration.java
@@ -18,9 +18,9 @@
     public ThreadPoolTaskExecutor threadPoolTaskExecutor() {
         ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
 
-        executor.setCorePoolSize(20);    // 核心线程数, 根据需求进行调整
-        executor.setMaxPoolSize(30);    // 最大线程数, 适当设置以避免资源耗尽
-        executor.setQueueCapacity(100);    // 队列容量, 适当限制以避免请求堆积
+        executor.setCorePoolSize(50);    // 核心线程数, 根据需求进行调整
+        executor.setMaxPoolSize(100);    // 最大线程数, 适当设置以避免资源耗尽
+        executor.setQueueCapacity(150);    // 队列容量, 适当限制以避免请求堆积
         executor.setKeepAliveSeconds(30);    // 线程空闲时的存活时间为30秒,减少系统开销
         executor.setThreadNamePrefix("Thread-");    // 线程名称的前缀
 
diff --git a/geteClient/src/main/java/org/example/geteclient/ThreadConfig/AsyncConfiguration.java b/geteClient/src/main/java/org/example/geteclient/ThreadConfig/AsyncConfiguration.java
index 06a876f..1b02748 100644
--- a/geteClient/src/main/java/org/example/geteclient/ThreadConfig/AsyncConfiguration.java
+++ b/geteClient/src/main/java/org/example/geteclient/ThreadConfig/AsyncConfiguration.java
@@ -18,8 +18,8 @@
     public ThreadPoolTaskExecutor threadPoolTaskExecutor() {
         ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
 
-        executor.setCorePoolSize(40);    // 核心线程数, 根据需求进行调整
-        executor.setMaxPoolSize(50);    // 最大线程数, 适当设置以避免资源耗尽
+        executor.setCorePoolSize(60);    // 核心线程数, 根据需求进行调整
+        executor.setMaxPoolSize(100);    // 最大线程数, 适当设置以避免资源耗尽
         executor.setQueueCapacity(400);    // 队列容量, 适当限制以避免请求堆积
         executor.setKeepAliveSeconds(30);    // 线程空闲时的存活时间为30秒,减少系统开销
         executor.setThreadNamePrefix("Thread-");    // 线程名称的前缀
diff --git a/kucoinClient/src/main/java/org/example/kucoinclient/ThreadConfig/AsyncConfiguration.java b/kucoinClient/src/main/java/org/example/kucoinclient/ThreadConfig/AsyncConfiguration.java
index b549313..f94fe7b 100644
--- a/kucoinClient/src/main/java/org/example/kucoinclient/ThreadConfig/AsyncConfiguration.java
+++ b/kucoinClient/src/main/java/org/example/kucoinclient/ThreadConfig/AsyncConfiguration.java
@@ -18,9 +18,9 @@
     public ThreadPoolTaskExecutor threadPoolTaskExecutor() {
         ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
 
-        executor.setCorePoolSize(20);    // 核心线程数, 根据需求进行调整
-        executor.setMaxPoolSize(30);    // 最大线程数, 适当设置以避免资源耗尽
-        executor.setQueueCapacity(100);    // 队列容量, 适当限制以避免请求堆积
+        executor.setCorePoolSize(50);    // 核心线程数, 根据需求进行调整
+        executor.setMaxPoolSize(100);    // 最大线程数, 适当设置以避免资源耗尽
+        executor.setQueueCapacity(150);    // 队列容量, 适当限制以避免请求堆积
         executor.setKeepAliveSeconds(30);    // 线程空闲时的存活时间为30秒,减少系统开销
         executor.setThreadNamePrefix("Thread-");    // 线程名称的前缀
 
diff --git a/mexcClient/src/main/java/org/example/mexcclient/ThreadConfig/AsyncConfiguration.java b/mexcClient/src/main/java/org/example/mexcclient/ThreadConfig/AsyncConfiguration.java
index 61c5a76..e4fdd1f 100644
--- a/mexcClient/src/main/java/org/example/mexcclient/ThreadConfig/AsyncConfiguration.java
+++ b/mexcClient/src/main/java/org/example/mexcclient/ThreadConfig/AsyncConfiguration.java
@@ -18,9 +18,9 @@
     public ThreadPoolTaskExecutor threadPoolTaskExecutor() {
         ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
 
-        executor.setCorePoolSize(100);    // 核心线程数, 根据需求进行调整
-        executor.setMaxPoolSize(150);    // 最大线程数, 适当设置以避免资源耗尽
-        executor.setQueueCapacity(200);    // 队列容量, 适当限制以避免请求堆积
+        executor.setCorePoolSize(150);    // 核心线程数, 根据需求进行调整
+        executor.setMaxPoolSize(200);    // 最大线程数, 适当设置以避免资源耗尽
+        executor.setQueueCapacity(300);    // 队列容量, 适当限制以避免请求堆积
         executor.setKeepAliveSeconds(30);    // 线程空闲时的存活时间为30秒,减少系统开销
         executor.setThreadNamePrefix("Thread-");    // 线程名称的前缀
 

--
Gitblit v1.9.3