From 52d0d62c35d01ee73d9dba7b1be99a29adc35ef2 Mon Sep 17 00:00:00 2001 From: 疯狂的狮子li <15040126243@163.com> Date: 星期二, 17 八月 2021 10:45:01 +0800 Subject: [PATCH] update 同步 ruoyi 适配改动 --- ruoyi-framework/src/main/java/com/ruoyi/framework/config/AsyncConfig.java | 15 ++++++++++----- 1 files changed, 10 insertions(+), 5 deletions(-) diff --git a/ruoyi-framework/src/main/java/com/ruoyi/framework/config/AsyncConfig.java b/ruoyi-framework/src/main/java/com/ruoyi/framework/config/AsyncConfig.java index 5c11ae6..e30f83c 100644 --- a/ruoyi-framework/src/main/java/com/ruoyi/framework/config/AsyncConfig.java +++ b/ruoyi-framework/src/main/java/com/ruoyi/framework/config/AsyncConfig.java @@ -1,7 +1,9 @@ package com.ruoyi.framework.config; -import com.ruoyi.common.exception.CustomException; +import com.ruoyi.common.exception.ServiceException; import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.context.annotation.Configuration; import org.springframework.scheduling.annotation.AsyncConfigurerSupport; import org.springframework.scheduling.annotation.EnableAsync; @@ -9,7 +11,7 @@ import java.util.Arrays; import java.util.concurrent.Executor; -import java.util.concurrent.Executors; +import java.util.concurrent.ScheduledExecutorService; /** * 寮傛閰嶇疆 @@ -20,13 +22,16 @@ @Configuration public class AsyncConfig extends AsyncConfigurerSupport { + @Autowired + @Qualifier("scheduledExecutorService") + private ScheduledExecutorService scheduledExecutorService; + /** * 寮傛鎵ц闇�瑕佷娇鐢ㄦ潈闄愭鏋惰嚜甯︾殑鍖呰绾跨▼姹� 淇濊瘉鏉冮檺淇℃伅鐨勪紶閫� */ @Override public Executor getAsyncExecutor() { - return new DelegatingSecurityContextExecutorService( - Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors())); + return new DelegatingSecurityContextExecutorService(scheduledExecutorService); } /** @@ -36,7 +41,7 @@ public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() { return (throwable, method, objects) -> { throwable.printStackTrace(); - throw new CustomException( + throw new ServiceException( "Exception message - " + throwable.getMessage() + ", Method name - " + method.getName() + ", Parameter value - " + Arrays.toString(objects)); -- Gitblit v1.9.3