@Async-线程池的优化使用技巧

1. @Async 注解

1.1 `@Async` 注解的含义

@Async 是 Spring 框架提供的一个注解，用于将某个方法标记为异步执行。也就是说，当标记了 @Async 的方法被调用时，Spring 会通过 AOP（Aspect-Oriented Programming）生成一个代理，在后台线程池中异步执行该方法，从而与主线程解耦。这样可以显著提升应用程序的并行执行能力，减少主线程的阻塞时间。

需要注意的是，@Async 能够生效有以下前提条件：

启用异步功能：需要在配置类或启动类上添加 @EnableAsync 注解。
方法的可见性和调用方式：通常要求目标方法是 public，且不能在同类内部直接调用（同类自调用会绕过 AOP 代理）。
使用合适的线程池：默认情况下，Spring 会使用一个简单的线程池执行异步方法，但在实际生产环境中通常需要自定义线程池来满足性能和可控性需求。

1.2 为什么会结合线程池使用

当一个方法标记为 @Async 时，Spring 会将该方法提交给线程池来执行，从而实现并发和异步能力。线程池可以带来以下好处：

线程复用：大量的任务可以复用固定数量的线程，避免频繁创建和销毁线程所带来的性能开销。
资源控制：通过配置核心线程数、最大线程数和队列大小等参数，可以有效控制系统资源占用，防止线程数无限制增长、内存耗尽或 CPU 过载。
灵活的拒绝策略：线程池提供不同的拒绝策略，帮助应对任务量激增导致的线程池资源不足的情况。
统一的监控管理：可以对线程池进行统一监控和调优，及时发现线程饱和、任务排队、执行延迟等问题。

因此，为了更好地管理和监控异步执行所占用的资源，@Async 与线程池往往会结合在一起使用：在 Spring 配置一个或多个自定义线程池，并在 @Async("beanName") 中显式指定需要使用的线程池。

1.3 直接使用 `@Async` 的坏处

Spring 提供的 @Async 注解在未指定线程池的情况下，默认会使用一个比较简单的线程池（如 SimpleAsyncTaskExecutor），这个默认线程池会有以下问题：

线程数不可控
默认的 SimpleAsyncTaskExecutor 可能会为每个任务都创建一个新线程，无法精确控制最大并发线程数。当任务过多时，容易导致线程数飙升，从而引发 CPU、内存等资源紧张。
无法进行定制化配置
无法配置核心线程数、最大线程数、队列大小、线程存活时间等参数，也无法设置拒绝策略，难以满足特定业务场景下的性能和可控性需求。
缺乏监控及异常处理手段
无法便捷地对线程池进行监控，无法轻松进行异常处理和报警，如线程池是否饱和、任务执行是否被拒绝等。

1.4 改进建议

自定义线程池：在 Spring 中配置一个或多个 ThreadPoolTaskExecutor（或直接使用 JDK 的 ThreadPoolExecutor），并在 @Async("beanName") 中指定使用该线程池。
合理设置线程池参数：根据系统硬件、业务逻辑和实际并发量，合理配置核心线程数、最大线程数、队列大小和存活时间等参数。
监控与报警：在生产环境中，最好对线程池的任务量、队列大小、拒绝次数等进行监控，并设置报警策略。
日志与调试：为线程设置合理的名字前缀，便于在日志或监控系统中识别线程来源；对可能发生的异常做好捕获和处理。

2. 自定义线程池的核心参数及含义

在 Java 中，如果使用 Spring 提供的 ThreadPoolTaskExecutor 或者直接使用 JDK 的 ThreadPoolExecutor，通常需要配置以下核心参数：

corePoolSize（核心线程数）
- 类型：int
- 含义：线程池常驻的最小线程数，即使线程处于空闲状态时也不会被销毁。
- 影响：决定并行度的基准，当有新任务提交时，如果线程数还没达到 corePoolSize，则会创建新的线程来处理任务。
maxPoolSize（最大线程数）
- 类型：int
- 含义：线程池能容纳的最大线程数。当队列已满且所有核心线程都在忙碌时，会继续创建新线程，直到总线程数到达 maxPoolSize。
- 影响：为应对高并发时提供一定的扩容能力。
keepAliveTime / keepAliveSeconds（线程存活时间）
- 类型：long / int（秒）
- 含义：当线程数多于核心线程数时，多余的线程在空闲多长时间后会被销毁。
- 影响：在业务峰值过后，回收空闲线程以释放系统资源。
queueCapacity（队列容量）
- 类型：int
- 含义：用来缓冲待执行任务的队列大小。
- 影响：当核心线程都忙碌时，新任务会放进队列等待；若队列也满了并且线程数尚未到达 maxPoolSize，才会继续创建新的线程。队列和线程都满了后，会触发拒绝策略。
threadNamePrefix（线程名前缀）
- 类型：String
- 含义：为线程池内的线程设置统一的名字前缀，方便在日志或监控系统中识别。
- 影响：仅影响线程名，对系统逻辑本身无直接影响，但对于排查问题非常有用。
rejectedExecutionHandler（拒绝策略）
- 类型：RejectedExecutionHandler
- 常见实现：
  - AbortPolicy（默认）：直接抛出 RejectedExecutionException
  - CallerRunsPolicy：由调用该任务的线程执行该任务
  - DiscardPolicy：直接丢弃任务，不抛异常
  - DiscardOldestPolicy：丢弃队列里最旧的一个任务，再将新任务加入队列
- 含义：当核心线程、队列以及最大线程数都已满时，新任务提交会触发拒绝策略。
- 影响：不同拒绝策略的选择会影响系统在高负载下对任务的处理方式。

3. `@Async` 结合自定义线程池如何使用

3.1 配置自定义线程池

在 Spring Boot 或 Spring 项目中，一般会创建一个配置类，用于注册自定义线程池并启用异步功能：

@Configuration
@EnableAsync  // 启用异步支持
public class AsyncConfig {

    @Bean(name = "customThreadPool")
    public Executor customThreadPool() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        // 设置核心线程数
        executor.setCorePoolSize(5);
        // 设置最大线程数
        executor.setMaxPoolSize(10);
        // 设置队列容量
        executor.setQueueCapacity(100);
        // 设置线程存活时间（秒）
        executor.setKeepAliveSeconds(60);
        // 设置线程名前缀
        executor.setThreadNamePrefix("Async-Executor-");
        // 设置拒绝策略
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        // 初始化
        executor.initialize();
        return executor;
    }
}

@EnableAsync：开启 Spring 异步执行能力。
@Bean(name = "customThreadPool")：注册线程池，并进行参数配置。

3.2 在方法上使用自定义线程池

只需在目标方法上使用 @Async("customThreadPool") 指定我们定义的线程池 Bean，便可让该方法在自定义线程池中异步执行：

@Service
public class SomeService {

    @Async("customThreadPool")
    public void doAsyncTask() {
        System.out.println("异步任务线程：" + Thread.currentThread().getName());
        // 执行真正的业务逻辑
    }
}

4. 哪些场景会导致 `@Async` 失效

方法不是 public
Spring AOP 默认只会对 public 方法进行代理；如果是 private、protected 或包可见方法，则不会被代理。
同一个类里自调用
在同一个类的非异步方法里调用自身的异步方法，实际上是调用当前对象的普通方法，跳过了 AOP 代理。
未开启异步功能
若忘记在配置类或启动类上使用 @EnableAsync，则 @Async 不会生效。
注解放错位置
@Async 通常应放在类或方法上；如果放在接口或接口方法上，Spring 可能只对实现类进行代理（视 proxy 配置而定），导致注解不生效。
AOP 配置不当
比如使用 spring.aop.proxy-target-class=false（JDK 动态代理）但类又没有实现接口，导致无法生成代理对象，@Async 也无法生效。

5. 不使用 `@Async`，如何使用自定义线程池

在某些场景下，如果不想启用 Spring 的异步注解机制（比如需要手动控制任务提交、获取任务执行结果等），可以直接在业务代码中注入或创建线程池，然后手动提交任务：

5.1 注入自定义线程池并手动提交任务

@Service
public class SomeService {

    @Resource(name = "customThreadPool")
    private Executor executor;

    public void doAsyncTaskManually() {
        // 强转为 ThreadPoolTaskExecutor，如果是 ExecutorService 也可以进行相应类型转换
        ThreadPoolTaskExecutor taskExecutor = (ThreadPoolTaskExecutor) executor;
        // 提交任务，获取 Future
        Future<?> future = taskExecutor.submit(() -> {
            System.out.println("手动提交的异步任务：" + Thread.currentThread().getName());
            // 执行真正的异步逻辑
        });
        // 如果需要，可以 future.get() 拿到执行结果（会阻塞）
    }
}

5.2 直接使用 JDK 的 `ThreadPoolExecutor`

public class MyThreadPoolUsage {
    private static ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(
            5, 
            10, 
            60, 
            TimeUnit.SECONDS, 
            new LinkedBlockingQueue<>(100),
            new ThreadFactoryBuilder().setNameFormat("MyPool-%d").build(),
            new ThreadPoolExecutor.AbortPolicy()
    );

    public static void main(String[] args) {
        // 提交任务
        threadPoolExecutor.execute(() -> {
            System.out.println("JDK ThreadPoolExecutor 异步任务：" + Thread.currentThread().getName());
        });
    }
}

这种方式就不依赖 Spring 的 AOP 机制，可以在纯 Java 项目中使用，也可以在 Spring 项目中通过 @Bean 注入为一个线程池实例后再使用。

6. 总结

@Async 注解的含义
- 通过 AOP 代理，实现方法异步执行，减少主线程阻塞、提高吞吐量。
为什么要结合线程池使用
- 线程池可复用线程、控制资源占用、设定拒绝策略并统一监控，能更好地管理异步任务。
直接使用 @Async 的坏处
- 默认线程池不可控，无法定制核心线程数、最大线程数、队列大小等。
自定义线程池的核心参数
- 包括 corePoolSize、maxPoolSize、keepAliveTime、queueCapacity、threadNamePrefix、rejectedExecutionHandler 等。
@Async 结合自定义线程池的正确使用
- 使用 @EnableAsync + 自定义 ThreadPoolTaskExecutor + @Async("beanName")。
@Async 失效场景
- 方法访问修饰符不是 public、同类自调用、未开启异步、AOP 代理配置不正确等。
不使用 @Async 的方式
- 通过注入或创建线程池（ThreadPoolTaskExecutor / ThreadPoolExecutor），手动提交异步任务并进行控制。

@Async-线程池的优化使用技巧