diff --git a/src/main/java/cn/van/business/config/AsyncConfig.java b/src/main/java/cn/van/business/config/AsyncConfig.java index 401cee0..18f6383 100644 --- a/src/main/java/cn/van/business/config/AsyncConfig.java +++ b/src/main/java/cn/van/business/config/AsyncConfig.java @@ -6,6 +6,7 @@ import org.springframework.scheduling.annotation.EnableAsync; import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; import java.util.concurrent.Executor; +import java.util.concurrent.ThreadPoolExecutor; /** * @author Leo @@ -20,11 +21,10 @@ public class AsyncConfig implements AsyncConfigurer { @Override public Executor getAsyncExecutor() { ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); - executor.setCorePoolSize(8); + executor.setCorePoolSize(10); executor.setMaxPoolSize(128); - executor.setQueueCapacity(100); - executor.setThreadNamePrefix("Async-"); + executor.setQueueCapacity(500); + executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); executor.initialize(); - return executor; } }