@Configuration
@EnableAsync
public class ScheduledConfig {
   /**
     * 創(chuàng)建并配置一個(gè)線程池，用于快速執(zhí)行任務(wù)。
     * 
     * @return Executor 返回一個(gè)配置好的線程池實(shí)例，可以用于快速執(zhí)行任務(wù)。
     */
    @Bean("baseExecutor")
    public Executor fastExecutor() {
        // 創(chuàng)建 ThreadPoolTaskExecutor 實(shí)例
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        // 設(shè)置線程名前綴
        executor.setThreadNamePrefix("xxxx-schedule-baseExecutor");
        // 設(shè)置最大線程池大小
        executor.setMaxPoolSize(10);
        // 設(shè)置核心線程池大小
        executor.setCorePoolSize(8);
        // 設(shè)置隊(duì)列容量
        executor.setQueueCapacity(5);
        // 設(shè)置拒絕執(zhí)行處理器，采用CallerRunsPolicy策略
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        return executor;
    }

@Configuration
@EnableAsync
public class ExecutorConfig {
	// 名字可以根據(jù)項(xiàng)目業(yè)務(wù)隨意起
    @Bean("baseExecutor")
    public Executor fastExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        // 線程名前綴保持不變
        executor.setThreadNamePrefix("xxxx-schedule-base");
        // 調(diào)整核心線程池大小、最大線程池大小和隊(duì)列容量，以適應(yīng)可能的更高負(fù)載
        executor.setCorePoolSize(16); // 增加核心線程數(shù)
        executor.setMaxPoolSize(20); // 增加最大線程數(shù)
        executor.setQueueCapacity(100); // 增加隊(duì)列容量
        // 使用自定義的RejectedExecutionHandler來處理任務(wù)被拒絕的情況
        executor.setRejectedExecutionHandler(new CustomRejectedExecutionHandler());
        // 確保在應(yīng)用停止時(shí)線程池能被正確關(guān)閉
        Runtime.getRuntime().addShutdownHook(new Thread(() -> {
            executor.shutdown();
        }));
        return executor;
    }
    // 自定義的拒絕執(zhí)行處理器，以更好地處理任務(wù)被拒絕的情況
    static class CustomRejectedExecutionHandler implements RejectedExecutionHandler {
        @Override
        public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
            // 這里可以加入更詳細(xì)的日志記錄或發(fā)送警報(bào)等邏輯
            System.out.println("Task " + r.toString() + " rejected from executor " + executor.toString());
        }
    }
}

@Async("baseExecutor")
@Scheduled(cron = "0 0/5 * * * ?"){
// 具體業(yè)務(wù)
}