From 5bac93baf5659ce013163f884c9dce41990a860e Mon Sep 17 00:00:00 2001
From: kimi42345 <kimi42345@outlook.com>
Date: 星期一, 23 三月 2020 08:49:41 +0800
Subject: [PATCH] no message
---
src/main/java/com/highdatas/mdm/util/OriginConfig.java | 36 ++++++++++++++++++++++++++++++++++--
1 files changed, 34 insertions(+), 2 deletions(-)
diff --git a/src/main/java/com/highdatas/mdm/util/OriginConfig.java b/src/main/java/com/highdatas/mdm/util/OriginConfig.java
index e8c424a..b00197a 100644
--- a/src/main/java/com/highdatas/mdm/util/OriginConfig.java
+++ b/src/main/java/com/highdatas/mdm/util/OriginConfig.java
@@ -1,11 +1,17 @@
package com.highdatas.mdm.util;
+import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler;
import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.AsyncConfigurer;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import org.springframework.web.servlet.config.annotation.CorsRegistry;
import org.springframework.web.servlet.config.annotation.InterceptorRegistration;
import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
+
+import java.util.concurrent.Executor;
/**
* @author kimi
@@ -14,7 +20,7 @@
*/
@Configuration
-public class OriginConfig implements WebMvcConfigurer {
+public class OriginConfig implements WebMvcConfigurer, AsyncConfigurer {
@Autowired
CommonInterceptor commonInterceptor;
@@ -30,7 +36,33 @@
@Override
public void addInterceptors(InterceptorRegistry registry) {
InterceptorRegistration interceptorRegistration = registry.addInterceptor(commonInterceptor);
- interceptorRegistration.excludePathPatterns("/designer/**","/upload/**", "/process/**", "/processes/**", "/swagger-ui.html", "/webjars/**", "/swagger-resources/**", "/v2/api-docs");
+ interceptorRegistration.excludePathPatterns("/designer/**","/upload/**", "/process/**", "/processes/**", "/swagger-ui.html", "/webjars/**", "/swagger-resources/**", "/v2/api-docs", "/");
+ }
+
+ @Override
+ @Bean
+ public Executor getAsyncExecutor() {
+ ThreadPoolTaskExecutor threadPool = new ThreadPoolTaskExecutor();
+ //璁剧疆鏍稿績绾跨▼鏁�
+ threadPool.setCorePoolSize(10);
+ //璁剧疆鏈�澶х嚎绋嬫暟
+ threadPool.setMaxPoolSize(100);
+ //绾跨▼姹犳墍浣跨敤鐨勭紦鍐查槦鍒�
+ threadPool.setQueueCapacity(10);
+ //绛夊緟浠诲姟鍦ㄥ叧鏈烘椂瀹屾垚--琛ㄦ槑绛夊緟鎵�鏈夌嚎绋嬫墽琛屽畬
+ threadPool.setWaitForTasksToCompleteOnShutdown(true);
+ // 绛夊緟鏃堕棿 锛堥粯璁や负0锛屾鏃剁珛鍗冲仠姝級锛屽苟娌＄瓑寰厁x绉掑悗寮哄埗鍋滄
+ threadPool.setAwaitTerminationSeconds(60);
+ // 绾跨▼鍚嶇О鍓嶇紑
+ threadPool.setThreadNamePrefix("MDM-Async-");
+ // 鍒濆鍖栫嚎绋�
+ threadPool.initialize();
+ return threadPool;
+ }
+
+ @Override
+ public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
+ return null;
}
}
--
Gitblit v1.8.0