ContiNew/continew-starter
1
1
Fork 0
mirror of https://github.com/continew-org/continew-starter.git synced 2025-09-09 20:57:23 +08:00
Code Issues Packages Projects Releases Wiki Activity

chore: 部分代码格式优化

Browse Source
This commit is contained in:
Charles7c
2024-04-16 22:44:33 +08:00
parent b0e567d749
commit 8695cf9e09
2 changed files with 3 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
continew-starter-core/src/main/java/top/continew/starter/core/autoconfigure/threadpool/ThreadPoolAutoConfiguration.java
View File

@@ -76,9 +76,8 @@ public class ThreadPoolAutoConfiguration {
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
// 关闭线程池是否等待任务完成 // 关闭线程池是否等待任务完成
executor.setWaitForTasksToCompleteOnShutdown(properties.isWaitForTasksToCompleteOnShutdown()); executor.setWaitForTasksToCompleteOnShutdown(properties.isWaitForTasksToCompleteOnShutdown());
// 执行器在关闭时阻塞的最长毫秒数，以等待剩余任务完成执行。 // 执行器在关闭时阻塞的最长毫秒数，以等待剩余任务完成执行
executor.setAwaitTerminationMillis(properties.getAwaitTerminationMillis()); executor.setAwaitTerminationMillis(properties.getAwaitTerminationMillis());
log.debug("[ContiNew Starter] - Auto Configuration 'ThreadPoolTaskExecutor' completed initialization."); log.debug("[ContiNew Starter] - Auto Configuration 'ThreadPoolTaskExecutor' completed initialization.");
return executor; return executor;
} }
@@ -99,9 +98,7 @@ public class ThreadPoolAutoConfiguration {
} }
}; };
// 应用关闭时，关闭线程池 // 应用关闭时，关闭线程池
SpringApplication.getShutdownHandlers().add(() -> { SpringApplication.getShutdownHandlers().add(() -> shutdown(executor, properties));
shutdown(executor, properties);
});
log.debug("[ContiNew Starter] - Auto Configuration 'ScheduledExecutorService' completed initialization."); log.debug("[ContiNew Starter] - Auto Configuration 'ScheduledExecutorService' completed initialization.");
return executor; return executor;
} }
@@ -132,7 +129,6 @@ public class ThreadPoolAutoConfiguration {
* *
* @param task the task to cancel (typically a {@link RunnableFuture}) * @param task the task to cancel (typically a {@link RunnableFuture})
* @see RunnableFuture#cancel(boolean) * @see RunnableFuture#cancel(boolean)
* @since 5.0.5
*/ */
protected void cancelRemainingTask(Runnable task) { protected void cancelRemainingTask(Runnable task) {
if (task instanceof Future<?> future) { if (task instanceof Future<?> future) {

2
continew-starter-core/src/main/java/top/continew/starter/core/autoconfigure/threadpool/ThreadPoolProperties.java
View File

@@ -60,7 +60,7 @@ public class ThreadPoolProperties {
private boolean waitForTasksToCompleteOnShutdown = false; private boolean waitForTasksToCompleteOnShutdown = false;
/** /**
* 执行器在关闭时阻塞的最长毫秒数，以等待剩余任务完成执行。 * 执行器在关闭时阻塞的最长毫秒数，以等待剩余任务完成执行
*/ */
private long awaitTerminationMillis = 0; private long awaitTerminationMillis = 0;