异步注解 Async

1、启动类开启异步线程

启动类上添加注解：@EnableAsync

2、配置线程池

示例：

import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.AsyncConfigurer;
import org.springframework.scheduling.annotation.EnableAsync;
import java.util.concurrent.*;

@Configuration
@EnableAsync
public class AsyncConfig implements AsyncConfigurer {

    @Bean(name = "customExecutor")
    public Executor customExecutor() {
        // 创建自定义线程池
        int corePoolSize = 10; // 核心线程数
        int maxPoolSize = 50; // 最大线程数
        long keepAliveTime = 60L; // 非核心线程空闲存活时间
        TimeUnit unit = TimeUnit.SECONDS; // 时间单位
        BlockingQueue<Runnable> workQueue = new LinkedBlockingQueue<>(); // 工作队列

        ThreadPoolExecutor executor = new ThreadPoolExecutor(
                corePoolSize,
                maxPoolSize,
                keepAliveTime,
                unit,
                workQueue
        );

        // 允许核心线程超时
        executor.allowCoreThreadTimeOut(true);

        // 设置线程工厂
        executor.setThreadFactory(new ThreadFactoryBuilder()
                .setNameFormat("custom-async-pool-%d") // 线程名称格式
                .build());

        // 设置拒绝策略
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());

        return executor;
    }

    @Override
    public Executor getAsyncExecutor() {
        // 返回自定义线程池
        return customExecutor();
    }

    @Override
    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
        // 设置异步执行时的异常处理器
        return new SimpleAsyncUncaughtExceptionHandler();
    }

    public static class SimpleAsyncUncaughtExceptionHandler implements AsyncUncaughtExceptionHandler {

        @Override
        public void handleUncaughtException(Throwable ex, Method method, Object... params) {
            System.err.println("Unhandled exception in " + method.getName() + " with parameters " + Arrays.deepToString(params));
            ex.printStackTrace();
        }
    }
}

在这个配置类中，我们完成了以下内容：

1. 通过 @Configuration 注解标注这个类是一个配置类。
2. 通过 @EnableAsync 注解开启异步支持。
3. 实现 AsyncConfigurer 接口，以自定义异步执行器和异常处理器。
4. 创建了一个 ThreadPoolExecutor 作为自定义线程池，配置了核心线程数、最大线程数、空闲存活时间、工作队列等参数。
5. 使用 ThreadFactoryBuilder 创建了一个命名的线程工厂。
6. 设置了拒绝策略为 CallerRunsPolicy，这意味着如果线程池达到饱和状态，任务将由调用者线程执行。
7. 实现了自定义的异常处理器 SimpleAsyncUncaughtExceptionHandler，用于处理异步方法执行中的未捕获异常。

3、方法体上添加异步注解

示例：

@Async
public void test() {
  
}

注意事项：

• 在内部类之间的方法调用，此注解无效，不会有异步线程
• 需要外部的类来调用这个异步方法才会开启异步线程

学习参考

• Springboot之@Async异步指定自定义线程池使用_async指定线程池-CSDN博客 (opens new window)