@Configuration
@EnableAsync(proxyTargetClass = true)
public class AsyncConfig implements AsyncConfigurer {
    @Override
    public Executor getAsyncExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        // 核心配置參數(shù)
        executor.setCorePoolSize(5);           // 核心線程數(shù)
        executor.setMaxPoolSize(10);           // 最大線程數(shù)
        executor.setQueueCapacity(25);         // 隊列容量
        executor.setThreadNamePrefix("async-task-");  // 線程命名
        executor.setKeepAliveSeconds(60);      // 線程存活時間
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); // 拒絕策略
        executor.initialize();  // 必須初始化
        return executor;
    }
}

// 業(yè)務(wù)場景 + 功能模塊
executor.setThreadNamePrefix("order-async-");
// 系統(tǒng)模塊 + 任務(wù)類型
executor.setThreadNamePrefix("payment-notify-");
// 環(huán)境標(biāo)識 + 業(yè)務(wù)類型
executor.setThreadNamePrefix("prod-user-sync-");

@Bean("orderAsyncExecutor")
public Executor orderAsyncExecutor() {
    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
    executor.setCorePoolSize(8);
    executor.setMaxPoolSize(20);
    executor.setQueueCapacity(100);
    executor.setKeepAliveSeconds(30);
    executor.setThreadNamePrefix("order-async-");
    executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
    executor.initialize();
    return executor;
}

@Bean("notifyAsyncExecutor")
public Executor notifyAsyncExecutor() {
    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
    executor.setCorePoolSize(4);
    executor.setMaxPoolSize(8);
    executor.setQueueCapacity(50);
    executor.setKeepAliveSeconds(60);
    executor.setThreadNamePrefix("notify-async-");
    executor.setRejectedExecutionHandler(new ThreadPoolExecutor.DiscardOldestPolicy());
    executor.initialize();
    return executor;
}

@Service
public class OrderService {
    @Async("orderAsyncExecutor")  // 指定訂單線程池
    public void processOrder(Order order) {
        // 訂單處理邏輯
    }
    @Async("notifyAsyncExecutor")  // 指定通知線程池
    public void sendNotify(Message message) {
        // 消息通知邏輯
    }
}

# application.yml 配置示例
async:
  executors:
    order:
      core-pool-size: 8
      max-pool-size: 20
      queue-capacity: 100
      thread-name-prefix: "order-async-"
    notify:
      core-pool-size: 4
      max-pool-size: 8
      queue-capacity: 50
      thread-name-prefix: "notify-async-"

@PreDestroy
public void destroy() {
    executor.shutdown();
    try {
        if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
            executor.shutdownNow();
        }
    } catch (InterruptedException e) {
        executor.shutdownNow();
        Thread.currentThread().interrupt();
    }
}

// 注冊線程池監(jiān)控指標(biāo)
@Bean
public MeterBinder taskExecutorMetrics(ThreadPoolTaskExecutor executor) {
    return registry -> {
        Gauge.builder("async.executor.active.threads", 
                     executor, 
                     ThreadPoolTaskExecutor::getActiveCount)
             .register(registry);
        Gauge.builder("async.executor.queue.size",
                     executor,
                     e -> e.getThreadPoolExecutor().getQueue().size())
             .register(registry);
    };
}