From 27d341342925f11c19fb7a31da7050f5e9041319 Mon Sep 17 00:00:00 2001
From: feiyu02 <risaku@163.com>
Date: 星期四, 19 十月 2023 17:52:29 +0800
Subject: [PATCH] 新增数据分析模块
---
src/main/java/com/flightfeather/monitor/config/TaskPoolConfig.kt | 30 ++++++++++++++++++++++++++++++
1 files changed, 30 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/flightfeather/monitor/config/TaskPoolConfig.kt b/src/main/java/com/flightfeather/monitor/config/TaskPoolConfig.kt
new file mode 100644
index 0000000..dc17489
--- /dev/null
+++ b/src/main/java/com/flightfeather/monitor/config/TaskPoolConfig.kt
@@ -0,0 +1,30 @@
+package com.flightfeather.monitor.config
+
+import org.springframework.scheduling.annotation.EnableAsync
+import org.springframework.aop.interceptor.AsyncExecutionAspectSupport
+import org.springframework.context.annotation.Bean
+import org.springframework.context.annotation.Configuration
+import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor
+import java.util.concurrent.Executor
+import java.util.concurrent.ThreadPoolExecutor
+
+@EnableAsync
+@Configuration
+class TaskPoolConfig {
+ @Bean(name = [AsyncExecutionAspectSupport.DEFAULT_TASK_EXECUTOR_BEAN_NAME])
+ fun taskExecutor(): Executor {
+ val executor = ThreadPoolTaskExecutor()
+ //鏍稿績绾跨▼姹犲ぇ灏�
+ executor.corePoolSize = 10
+ //鏈�澶х嚎绋嬫暟
+ executor.maxPoolSize = 20
+ //闃熷垪瀹归噺
+ executor.queueCapacity = 200
+ //娲昏穬鏃堕棿
+ executor.keepAliveSeconds = 60
+ //绾跨▼鍚嶅瓧鍓嶇紑
+ executor.setThreadNamePrefix("taskExecutor-")
+ executor.setRejectedExecutionHandler(ThreadPoolExecutor.CallerRunsPolicy())
+ return executor
+ }
+}
\ No newline at end of file
--
Gitblit v1.9.3