Spring Boot如何正确实现多线程并行处理列表，排查@Async配置不生效问题

问题根因 #

你现在的写法存在三处核心问题导致没有实现并行效果：

1. @Async注解位置错误：你把@Async加在startProcess方法上，仅会将整个startProcess作为单个任务提交到线程池执行，方法内部的forEach循环还是在这一个异步线程里串行执行每一个runThreads逻辑，自然没有并行效果。
2. Spring @Async注解不支持本类内部调用与私有方法：@Async基于Spring AOP代理生效，只有外部调用代理类的public方法时注解才会生效，你在本类直接调用私有方法runThreads不会走代理逻辑，哪怕你给runThreads加@Async也不会生效。
3. 你贴出的startProcess代码存在笔误：方法内直接调用myObject.getAStringValue()时，myObject变量还未定义，代码本身编译不通过，需要先修正变量来源。

解决方案 #

推荐两种可落地的实现方式，你可以根据自己的业务场景选择：

方案1：使用CompletableFuture配合现有线程池（改造成本最低） #

不需要调整现有方法的访问权限，直接复用你已经定义好的线程池即可，代码修改如下：
首先在ApplicationServiceImpl中注入你配置的线程池：

@Autowired
@Qualifier("threadPoolTaskExecutor")
private Executor asyncExecutor;

然后修改startProcess方法：

@Override
public ResponseEntity<Void> startProcess(List<MyObject> myObjectList) throws Exception {
    // 提交所有任务到线程池并行执行
    List<CompletableFuture<Void>> taskFutures = myObjectList.stream()
            .map(myObject -> CompletableFuture.runAsync(() -> {
                // 修正变量获取逻辑，如果你这两个参数是公共值可以提前提取到循环外
                String aStringValue = myObject.getAStringValue();
                String anotherStringValue = myObject.getAnotherStringValue();
                runThreads(myObject, aStringValue, anotherStringValue);
            }, asyncExecutor))
            .toList();
    
    // 如果你需要等待所有任务执行完成再返回接口响应，保留下面这句；不需要的话可以删掉直接返回
    CompletableFuture.allOf(taskFutures.toArray(new CompletableFuture[0])).join();
    
    return ResponseEntity.ok().build();
}

方案2：修正@Async的使用方式 #

如果你更倾向用@Async注解实现，需要调整代码结构保证注解生效：

1. 把异步执行逻辑抽成独立公共Bean的公共方法，添加@Async注解：

@Service
public class AsyncTaskService {
    // 把你原来的runMethodA/B/C/D逻辑挪到这个类，或者注入对应的依赖
    
    @Async("threadPoolTaskExecutor")
    public void processSingleObject(MyObject myObject, String aStringValue, String anotherStringValue) {
        AnotherTypeOfObject anotherTypeOfObject = runMethodA(myObject);
        YetAnotherTypeOfObject yetAnotherTypeOfObject = runMethodB(anotherTypeOfObject);
        runMethodC(yetAnotherTypeOfObject, aStringValue, anotherStringValue);
        runMethodD(yetAnotherTypeOfObject);
    }
}

2. 在原来的ApplicationServiceImpl中注入这个异步任务Bean，循环调用即可：

@Service
public ApplicationServiceImpl implements ApplicationService {
    @Autowired
    private AsyncTaskService asyncTaskService;

    @Override
    public ResponseEntity<Void> startProcess(List<MyObject> myObjectList) throws Exception {
        myObjectList.forEach(myObject -> {
            String aStringValue = myObject.getAStringValue();
            String anotherStringValue = myObject.getAnotherStringValue();
            asyncTaskService.processSingleObject(myObject, aStringValue, anotherStringValue);
        });
        return ResponseEntity.ok().build();
    }
}

额外注意事项 #

• 你当前配置的线程池核心/最大线程数都是4，队列容量50，当待处理的MyObject数量超过54时，多余的任务会触发默认的AbortPolicy拒绝策略直接抛异常，你可以根据业务量调整线程池参数、队列长度，或者设置threadPoolTaskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy())让调用线程帮忙执行溢出的任务，避免任务丢失。
• 如果需要捕获异步任务的执行异常，可以在runThreads/processSingleObject方法内添加try-catch逻辑，或者用CompletableFuture的exceptionally方法统一处理。
• 如果你的业务逻辑依赖ThreadLocal存储的上下文（比如用户登录信息、请求上下文），默认异步线程是拿不到的，需要自行做上下文传递。

内容的提问来源于stack exchange，提问作者gtludwig