Spring 提供了 ThreadPoolTaskExecutor，它是一个封装了 Java 原生线程池的类，并且集成了 Spring 的一些功能。
步骤：
- 创建线程池配置类，使用
ThreadPoolTaskExecutor来配置线程池。 - 在服务类中注入
TaskExecutor并使用。
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import java.util.concurrent.Executor;
@Configuration
@EnableAsync // 启用异步执行
public class ThreadPoolConfig {
@Bean(name = "taskExecutor")
public Executor taskExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
// 设置线程池参数
executor.setCorePoolSize(10); // 核心线程数
executor.setMaxPoolSize(50); // 最大线程数
executor.setQueueCapacity(100); // 队列容量
executor.setThreadNamePrefix("myExecutor-"); // 线程名前缀
executor.initialize(); // 初始化线程池
return executor;
}
}
使用线程池：
一旦线程池配置完成，你就可以在需要执行异步任务的地方使用线程池。通过 @Async 注解来异步执行方法。
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
@Service
public class MyService {
@Async("taskExecutor") // 使用指定的线程池
public void asyncMethod() {
System.out.println("异步执行的任务，线程名称：" + Thread.currentThread().getName());
}
}