From 2f55cebbad3dea187a5f91d16ec80a9677dab699 Mon Sep 17 00:00:00 2001
From: 13693261870 <252740454@qq.com>
Date: 星期三, 13 十一月 2024 11:16:53 +0800
Subject: [PATCH] 1
---
src/main/java/com/yssh/config/ThreadPoolConfig.java | 14 +-------------
1 files changed, 1 insertions(+), 13 deletions(-)
diff --git a/src/main/java/com/yssh/config/ThreadPoolConfig.java b/src/main/java/com/yssh/config/ThreadPoolConfig.java
index 1a03fbf..ab44434 100644
--- a/src/main/java/com/yssh/config/ThreadPoolConfig.java
+++ b/src/main/java/com/yssh/config/ThreadPoolConfig.java
@@ -7,27 +7,17 @@
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
-/**
- * 绾跨▼姹犻厤缃�
- *
- * @author tam
- **/
@Configuration
@EnableAsync
public class ThreadPoolConfig {
- // 鏍稿績绾跨▼姹犲ぇ灏�
private int corePoolSize = 50;
- // 鏈�澶у彲鍒涘缓鐨勭嚎绋嬫暟
private int maxPoolSize = 200;
- // 闃熷垪鏈�澶ч暱搴�
private int queueCapacity = 1000;
- // 绾跨▼姹犵淮鎶ょ嚎绋嬫墍鍏佽鐨勭┖闂叉椂闂�
private int keepAliveSeconds = 300;
-
- //閰嶇疆绾跨▼姹犱腑鐨勭嚎绋嬬殑鍚嶇О鍓嶇紑
+
private String threadNamePrefix = "async-importDB-";
@Bean(name = "threadPoolTaskExecutor")
@@ -38,9 +28,7 @@
executor.setQueueCapacity(queueCapacity);
executor.setKeepAliveSeconds(keepAliveSeconds);
executor.setThreadNamePrefix(threadNamePrefix);
- // 绾跨▼姹犲鎷掔粷浠诲姟(鏃犵嚎绋嬪彲鐢�)鐨勫鐞嗙瓥鐣�
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
return executor;
}
-
}
--
Gitblit v1.9.3