From 15369bf819ca82896bbcada782e6babf2a7d64c9 Mon Sep 17 00:00:00 2001
From: cjl <276999030@qq.com>
Date: Tue, 14 Nov 2023 13:49:26 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/cjl' into qa
---
screen-api/src/main/java/com/moral/api/config/Interceptor/SyncConfiguration.java | 42 ++++++++++++++++++++++++++++++++++++++++++
1 files changed, 42 insertions(+), 0 deletions(-)
diff --git a/screen-api/src/main/java/com/moral/api/config/Interceptor/SyncConfiguration.java b/screen-api/src/main/java/com/moral/api/config/Interceptor/SyncConfiguration.java
new file mode 100644
index 0000000..ea9663f
--- /dev/null
+++ b/screen-api/src/main/java/com/moral/api/config/Interceptor/SyncConfiguration.java
@@ -0,0 +1,42 @@
+package com.moral.api.config.Interceptor;
+
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.EnableAsync;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
+
+import java.util.concurrent.ThreadPoolExecutor;
+
+//@Configuration
+@EnableAsync
+public class SyncConfiguration {
+
+ @Bean(name = "asyncPoolTaskExecutor")
+ public ThreadPoolTaskExecutor executor() {
+ ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
+ //���������������
+ taskExecutor.setCorePoolSize(10);
+ //������������������������������������,���������������������������������������������������������������������������
+ taskExecutor.setMaxPoolSize(20);
+ //������������
+ taskExecutor.setQueueCapacity(50);
+ //������������������,���������������������������������������������������������������������������������
+ taskExecutor.setKeepAliveSeconds(200);
+ //������������������������������
+ taskExecutor.setThreadNamePrefix("async-");
+ /**
+ * ������������������������������������������������������������������������������maximumPoolSize���������������������������������������������������������
+ * ������������������������������
+ * ThreadPoolExecutor.AbortPolicy:���������������������RejectedExecutionException���������
+ * ThreadPoolExecutor.DiscardPolicy������������������������������������������������
+ * ThreadPoolExecutor.DiscardOldestPolicy���������������������������������������������������������������������������������������
+ * ThreadPoolExecutor.CallerRunsPolicy��������������������������������������������������� execute() ���������������������
+ */
+ taskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
+ taskExecutor.initialize();
+ return taskExecutor;
+ }
+
+
+}
--
Gitblit v1.8.0