文件位置

src/main/java/com/yaoyaozw/customer/ThreadConfig.java

-package com.yaoyaozw.customer;
-
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-import org.springframework.scheduling.annotation.EnableAsync;
-import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
-
-import java.util.concurrent.ThreadPoolExecutor;
-
-/**
- * @author darker
- * @date 2022/8/2 15:01
- */
-@Configuration
-@EnableAsync
-public class ThreadConfig {
-
-    /** 核心线程数（默认线程数） */
-    private static final int CORE_POOL_SIZE = 15;
-    /** 最大线程数 */
-    private static final int MAX_POOL_SIZE = 50;
-    /** 允许线程空闲时间（单位：默认为秒） */
-    private static final int KEEP_ALIVE_TIME = 60;
-    /** 缓冲队列大小 */
-    private static final int QUEUE_CAPACITY = 100;
-    /** 线程池名前缀 */
-    private static final String THREAD_NAME_PREFIX = "Async-Service-";
-
-    @Bean("myExecutor")
-    public ThreadPoolTaskExecutor myExecutor() {
-        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
-        executor.setCorePoolSize(CORE_POOL_SIZE);
-        executor.setMaxPoolSize(MAX_POOL_SIZE);
-        executor.setQueueCapacity(QUEUE_CAPACITY);
-        executor.setKeepAliveSeconds(KEEP_ALIVE_TIME);
-        executor.setThreadNamePrefix(THREAD_NAME_PREFIX);
-
-        // 线程池对拒绝任务的处理策略
-        // CallerRunsPolicy：由调用线程（提交任务的线程）处理该任务
-        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
-        // 初始化
-        executor.initialize();
-        return executor;
-    }
-}

src/main/java/com/yaoyaozw/customer/AsynchronousSpringEventsConfig.java → src/main/java/com/yaoyaozw/customer/configs/AsynchronousSpringEventsConfig.java

-package com.yaoyaozw.customer;
+package com.yaoyaozw.customer.configs;
 
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.event.ApplicationEventMulticaster;