From 05c18827b11541fc9dc04e751e087d98503154fe Mon Sep 17 00:00:00 2001 From: liaozan <378024053@qq.com> Date: Thu, 26 Oct 2023 16:07:52 +0800 Subject: [PATCH] Polish --- .../util/support/task/ThreadPoolConfiguration.java | 10 +++++----- ...java => UnCaughtExceptionHandlerThreadFactory.java} | 8 ++++---- 2 files changed, 9 insertions(+), 9 deletions(-) rename commons/common-util/src/main/java/com/schbrain/common/util/support/task/{UnCaughtExceptionHandleThreadFactory.java => UnCaughtExceptionHandlerThreadFactory.java} (75%) diff --git a/commons/common-util/src/main/java/com/schbrain/common/util/support/task/ThreadPoolConfiguration.java b/commons/common-util/src/main/java/com/schbrain/common/util/support/task/ThreadPoolConfiguration.java index b214c47..e9001b9 100644 --- a/commons/common-util/src/main/java/com/schbrain/common/util/support/task/ThreadPoolConfiguration.java +++ b/commons/common-util/src/main/java/com/schbrain/common/util/support/task/ThreadPoolConfiguration.java @@ -13,16 +13,16 @@ import org.springframework.context.annotation.Configuration; public class ThreadPoolConfiguration { @Bean - public TaskExecutorCustomizer mdcSupportTaskExecutorCustomizer() { + public TaskExecutorCustomizer exceptionHandlerAwareTaskExecutorCustomizer() { return taskExecutor -> { taskExecutor.setTaskDecorator(new MdcContextPropagationTaskDecorator()); - taskExecutor.setThreadFactory(new UnCaughtExceptionHandleThreadFactory(taskExecutor)); + taskExecutor.setThreadFactory(new UnCaughtExceptionHandlerThreadFactory(taskExecutor)); }; } @Bean - public TaskSchedulerCustomizer mdcSupportTaskSchedulerCustomizer() { - return taskScheduler -> taskScheduler.setThreadFactory(new UnCaughtExceptionHandleThreadFactory(taskScheduler)); + public TaskSchedulerCustomizer exceptionHandlerAwareTaskSchedulerCustomizer() { + return taskScheduler -> taskScheduler.setThreadFactory(new UnCaughtExceptionHandlerThreadFactory(taskScheduler)); } -} \ No newline at end of file +} diff --git a/commons/common-util/src/main/java/com/schbrain/common/util/support/task/UnCaughtExceptionHandleThreadFactory.java b/commons/common-util/src/main/java/com/schbrain/common/util/support/task/UnCaughtExceptionHandlerThreadFactory.java similarity index 75% rename from commons/common-util/src/main/java/com/schbrain/common/util/support/task/UnCaughtExceptionHandleThreadFactory.java rename to commons/common-util/src/main/java/com/schbrain/common/util/support/task/UnCaughtExceptionHandlerThreadFactory.java index 59e4bb6..a405c2b 100644 --- a/commons/common-util/src/main/java/com/schbrain/common/util/support/task/UnCaughtExceptionHandleThreadFactory.java +++ b/commons/common-util/src/main/java/com/schbrain/common/util/support/task/UnCaughtExceptionHandlerThreadFactory.java @@ -9,11 +9,11 @@ import java.util.concurrent.ThreadFactory; * @author liaozan * @since 2022/1/11 */ -public class UnCaughtExceptionHandleThreadFactory implements ThreadFactory { +public class UnCaughtExceptionHandlerThreadFactory implements ThreadFactory { private final ThreadFactory delegate; - public UnCaughtExceptionHandleThreadFactory(ThreadFactory delegate) { + public UnCaughtExceptionHandlerThreadFactory(ThreadFactory delegate) { this.delegate = delegate; } @@ -25,7 +25,7 @@ public class UnCaughtExceptionHandleThreadFactory implements ThreadFactory { } @Slf4j - public static class LoggingUnCaughtExceptionHandler implements UncaughtExceptionHandler { + private static class LoggingUnCaughtExceptionHandler implements UncaughtExceptionHandler { @Override public void uncaughtException(Thread thread, Throwable throwable) { @@ -35,4 +35,4 @@ public class UnCaughtExceptionHandleThreadFactory implements ThreadFactory { } -} \ No newline at end of file +} -- GitLab