From aaa373bdcf60a172b349af96d3c0ccc2559fa7c3 Mon Sep 17 00:00:00 2001 From: dqjdda <201507802@qq.com> Date: Fri, 1 Nov 2019 09:16:44 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BB=A3=E7=A0=81=E4=BC=98=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../zhengjie/config/thread/AsyncTaskExecutePool.java | 12 ++++-------- .../config/thread/ThreadPoolExecutorUtil.java | 2 +- 2 files changed, 5 insertions(+), 9 deletions(-) diff --git a/eladmin-system/src/main/java/me/zhengjie/config/thread/AsyncTaskExecutePool.java b/eladmin-system/src/main/java/me/zhengjie/config/thread/AsyncTaskExecutePool.java index cc3b21c5..105aad45 100644 --- a/eladmin-system/src/main/java/me/zhengjie/config/thread/AsyncTaskExecutePool.java +++ b/eladmin-system/src/main/java/me/zhengjie/config/thread/AsyncTaskExecutePool.java @@ -5,7 +5,6 @@ import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler; import org.springframework.context.annotation.Configuration; import org.springframework.scheduling.annotation.AsyncConfigurer; import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; -import java.lang.reflect.Method; import java.util.concurrent.Executor; import java.util.concurrent.ThreadPoolExecutor; @@ -37,7 +36,7 @@ public class AsyncTaskExecutePool implements AsyncConfigurer { //活跃时间 executor.setKeepAliveSeconds(config.getKeepAliveSeconds()); //线程名字前缀 - executor.setThreadNamePrefix("el-executor-"); + executor.setThreadNamePrefix("el-async-"); // setRejectedExecutionHandler：当pool已经达到max size的时候，如何处理新任务 // CallerRunsPolicy：不在新线程中执行任务，而是由调用者所在的线程来执行 executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); @@ -47,12 +46,9 @@ public class AsyncTaskExecutePool implements AsyncConfigurer { @Override public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() { - return new AsyncUncaughtExceptionHandler() { - @Override - public void handleUncaughtException(Throwable throwable, Method method, Object... objects) { - log.error("=========================="+throwable.getMessage()+"=======================", throwable); - log.error("exception method:"+method.getName()); - } + return (throwable, method, objects) -> { + log.error("===="+throwable.getMessage()+"====", throwable); + log.error("exception method:"+method.getName()); }; } } diff --git a/eladmin-system/src/main/java/me/zhengjie/config/thread/ThreadPoolExecutorUtil.java b/eladmin-system/src/main/java/me/zhengjie/config/thread/ThreadPoolExecutorUtil.java index 963995fb..92627465 100644 --- a/eladmin-system/src/main/java/me/zhengjie/config/thread/ThreadPoolExecutorUtil.java +++ b/eladmin-system/src/main/java/me/zhengjie/config/thread/ThreadPoolExecutorUtil.java @@ -20,7 +20,7 @@ public class ThreadPoolExecutorUtil { properties.getMaxPoolSize(), properties.getKeepAliveSeconds(), TimeUnit.SECONDS, - new ArrayBlockingQueue(properties.getQueueCapacity()), + new ArrayBlockingQueue<>(properties.getQueueCapacity()), new TheadFactoryName() ); }