@Configuration
@EnableAsync
public class ThreadPoolConfig {
    
    @Bean(name = "customThreadPool")
    public ThreadPoolTaskExecutor threadPoolTaskExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(5); // 核心線程數(shù)
        executor.setMaxPoolSize(10); // 最大線程數(shù)
        executor.setQueueCapacity(20); // 隊(duì)列容量
        executor.setKeepAliveSeconds(30); // 線程空閑時(shí)間
        executor.setThreadNamePrefix("custom-thread-"); // 線程名前綴
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); // 拒絕策略
        executor.initialize();
        return executor;
    }
}

# application.properties配置示例
spring.task.execution.pool.core-size=5
spring.task.execution.pool.max-size=10
spring.task.execution.pool.queue-capacity=50
spring.task.execution.pool.keep-alive=60s
spring.task.execution.thread-name-prefix=task-
spring.task.execution.pool.allow-core-thread-timeout=false

@Configuration
@EnableAsync
public class ThreadPoolConfiguration {
    
    @Value("${spring.task.execution.pool.core-size}")
    private int corePoolSize;
    
    @Value("${spring.task.execution.pool.max-size}")
    private int maxPoolSize;
    
    @Bean
    public ThreadPoolTaskExecutor threadPoolTaskExecutor() {
        // 使用注入的值配置線程池
    }
}

@Service
public class AsyncService {
    
    @Async("customThreadPool") // 指定使用自定義線程池
    public void executeAsyncTask() {
        System.out.println("異步任務(wù)執(zhí)行在: " + Thread.currentThread().getName());
        // 執(zhí)行耗時(shí)操作
    }
}

@RestController
public class AsyncController {
    
    @Autowired
    private AsyncService asyncService;
    
    @GetMapping("/execute")
    public String executeTask() {
        asyncService.executeAsyncTask();
        return "異步任務(wù)已觸發(fā)!";
    }
}

@Service
public class TaskService {
    
    @Autowired
    @Qualifier("customThreadPool")
    private ThreadPoolTaskExecutor taskExecutor;
    
    public void executeTask(Runnable task) {
        taskExecutor.execute(task);
    }
    
    public Future<String> submitTask(Callable<String> task) {
        return taskExecutor.submit(task);
    }
}

@Configuration
@EnableAsync
public class MultiThreadPoolConfig {
    
    @Bean("taskExecutor")
    public AsyncTaskExecutor taskExecutor() {
        return createExecutor("taskExecutor-", 10, 50, 200);
    }
    
    @Bean("ioExecutor")
    public AsyncTaskExecutor ioExecutor() {
        return createExecutor("ioExecutor-", 5, 30, 100);
    }
    
    private AsyncTaskExecutor createExecutor(String prefix, int corePoolSize, 
                                          int maxPoolSize, int queueCapacity) {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(corePoolSize);
        executor.setMaxPoolSize(maxPoolSize);
        executor.setQueueCapacity(queueCapacity);
        executor.setThreadNamePrefix(prefix);
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        executor.initialize();
        return executor;
    }
}

@Configuration
@ConfigurationProperties(prefix = "task.pool")
public class TaskThreadPoolConfig {
    private int corePoolSize;
    private int maxPoolSize;
    private int keepAliveSeconds;
    private int queueCapacity;
    // getter和setter方法
}

@Configuration
@EnableAsync
public class TaskExecutePool {
    
    @Autowired
    private TaskThreadPoolConfig config;
    
    @Bean
    public Executor myTaskAsyncPool() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(config.getCorePoolSize());
        executor.setMaxPoolSize(config.getMaxPoolSize());
        executor.setQueueCapacity(config.getQueueCapacity());
        executor.setKeepAliveSeconds(config.getKeepAliveSeconds());
        executor.setThreadNamePrefix("MyExecutor-");
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        executor.initialize();
        return executor;
    }
}

task.pool.corePoolSize=20
task.pool.maxPoolSize=40
task.pool.keepAliveSeconds=300
task.pool.queueCapacity=50

@Configuration
public class NativeAsyncTaskExecutePool implements AsyncConfigurer {
    
    @Autowired
    TaskThreadPoolConfig config;
    
    @Override
    public Executor getAsyncExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(config.getCorePoolSize());
        executor.setMaxPoolSize(config.getMaxPoolSize());
        executor.setQueueCapacity(config.getQueueCapacity());
        executor.setKeepAliveSeconds(config.getKeepAliveSeconds());
        executor.setThreadNamePrefix("MyExecutor-");
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        executor.initialize();
        return executor;
    }
    
    @Override
    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
        return (throwable, method, objects) -> {
            // 異常處理邏輯
        };
    }
}

@RestController
public class ThreadPoolMonitorController {
    
    @Autowired
    @Qualifier("customThreadPool")
    private ThreadPoolTaskExecutor executor;
    
    @GetMapping("/pool/status")
    public Map<String, Object> getPoolStatus() {
        Map<String, Object> status = new HashMap<>();
        status.put("activeCount", executor.getActiveCount());
        status.put("poolSize", executor.getPoolSize());
        status.put("corePoolSize", executor.getCorePoolSize());
        status.put("maxPoolSize", executor.getMaxPoolSize());
        status.put("queueSize", executor.getThreadPoolExecutor().getQueue().size());
        status.put("completedTaskCount", executor.getThreadPoolExecutor().getCompletedTaskCount());
        return status;
    }
}