From 471f693ac87a6ed6a2b00e93472b025266c0271f Mon Sep 17 00:00:00 2001
From: jinpengyong <jpy123456>
Date: Mon, 13 Nov 2023 09:27:19 +0800
Subject: [PATCH] Merge branch 'wb' of http://blit.7drlb.com:8888/r/moral 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