From 8695cf9e0945583acb0ba60d2de6161cd3602fe4 Mon Sep 17 00:00:00 2001 From: Charles7c Date: Tue, 16 Apr 2024 22:44:33 +0800 Subject: [PATCH] =?UTF-8?q?chore:=20=E9=83=A8=E5=88=86=E4=BB=A3=E7=A0=81?= =?UTF-8?q?=E6=A0=BC=E5=BC=8F=E4=BC=98=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../threadpool/ThreadPoolAutoConfiguration.java | 8 ++------ .../autoconfigure/threadpool/ThreadPoolProperties.java | 2 +- 2 files changed, 3 insertions(+), 7 deletions(-) diff --git a/continew-starter-core/src/main/java/top/continew/starter/core/autoconfigure/threadpool/ThreadPoolAutoConfiguration.java b/continew-starter-core/src/main/java/top/continew/starter/core/autoconfigure/threadpool/ThreadPoolAutoConfiguration.java index 0b8e1410..400b70df 100644 --- a/continew-starter-core/src/main/java/top/continew/starter/core/autoconfigure/threadpool/ThreadPoolAutoConfiguration.java +++ b/continew-starter-core/src/main/java/top/continew/starter/core/autoconfigure/threadpool/ThreadPoolAutoConfiguration.java @@ -76,9 +76,8 @@ public class ThreadPoolAutoConfiguration { executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); // 关闭线程池是否等待任务完成 executor.setWaitForTasksToCompleteOnShutdown(properties.isWaitForTasksToCompleteOnShutdown()); - // 执行器在关闭时阻塞的最长毫秒数，以等待剩余任务完成执行。 + // 执行器在关闭时阻塞的最长毫秒数，以等待剩余任务完成执行 executor.setAwaitTerminationMillis(properties.getAwaitTerminationMillis()); - log.debug("[ContiNew Starter] - Auto Configuration 'ThreadPoolTaskExecutor' completed initialization."); return executor; } @@ -99,9 +98,7 @@ public class ThreadPoolAutoConfiguration { } }; // 应用关闭时，关闭线程池 - SpringApplication.getShutdownHandlers().add(() -> { - shutdown(executor, properties); - }); + SpringApplication.getShutdownHandlers().add(() -> shutdown(executor, properties)); log.debug("[ContiNew Starter] - Auto Configuration 'ScheduledExecutorService' completed initialization."); return executor; } @@ -132,7 +129,6 @@ public class ThreadPoolAutoConfiguration { * * @param task the task to cancel (typically a {@link RunnableFuture}) * @see RunnableFuture#cancel(boolean) - * @since 5.0.5 */ protected void cancelRemainingTask(Runnable task) { if (task instanceof Future future) { diff --git a/continew-starter-core/src/main/java/top/continew/starter/core/autoconfigure/threadpool/ThreadPoolProperties.java b/continew-starter-core/src/main/java/top/continew/starter/core/autoconfigure/threadpool/ThreadPoolProperties.java index 5fa2114a..1afb7fd5 100644 --- a/continew-starter-core/src/main/java/top/continew/starter/core/autoconfigure/threadpool/ThreadPoolProperties.java +++ b/continew-starter-core/src/main/java/top/continew/starter/core/autoconfigure/threadpool/ThreadPoolProperties.java @@ -60,7 +60,7 @@ public class ThreadPoolProperties { private boolean waitForTasksToCompleteOnShutdown = false; /** - * 执行器在关闭时阻塞的最长毫秒数，以等待剩余任务完成执行。 + * 执行器在关闭时阻塞的最长毫秒数，以等待剩余任务完成执行 */ private long awaitTerminationMillis = 0;