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 b214c4720bff11c34dc0be678f4295f0f736bef1..e9001b9bf60feca717e9a06bc8e1588c7a7949c6 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 59e4bb6a4a70caba4ec2eab0bb9b84ea178fd4cb..a405c2b79e5a7975c6821ceec33fa17b016a6580 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 +}