在Spring Boot中，使用@Async注解可以创建异步任务。为了确保异步任务之间具有足够的隔离性，特别是在使用线程池时，我们需要为每个@Async注解的方法配置不同的线程池。
以下是一个配置异步任务线程池的示例代码：
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.AsyncConfigurer;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import java.util.concurrent.Executor;
@Configuration
public class AsyncConfig implements AsyncConfigurer {
@Bean(name = "taskExecutor1")
@Override
public Executor getAsyncExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(5);
executor.setMaxPoolSize(10);
executor.setQueueCapacity(25);
executor.initialize();
return executor;
}
@Bean(name = "taskExecutor2")
@Override
public Executor getAsyncExecutor2() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(5);
executor.setMaxPoolSize(10);
executor.setQueueCapacity(25);
executor.initialize();
return executor;
}
}在这个配置中，我们定义了两个不同的线程池。第一个线程池名为taskExecutor1，第二个线程池名为taskExecutor2。每个异步任务可以指定使用哪个线程池：
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
@Service
public class AsyncService {
@Async("taskExecutor1")
public void asyncTask1() {
// 异步任务1的执行逻辑
}
@Async("taskExecutor2")
public void asyncTask2() {
// 异步任务2的执行逻辑
}
}在这个例子中，asyncTask1使用taskExecutor1线程池，asyncTask2使用taskExecutor2线程池。这样，即使有多个异步任务同时运行，它们之间也可以彼此独立，减少了线程安全问题。