SpringBoot 多线程
实现起来挺简单的,使用注解即可。
当我们一些业务可以异步执行的时候,可以交给子线程去完成,加快返回结果的速度。
多线程实现
- 线程池配置
- 使用子线程
- 注意事项
线程池配置
@Configuration
public class AsyncConfiguration {
@Bean("commonExecutor")
public Executor cacheUpdateExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
// 核心线程数:线程池创建时候初始化的线程数
executor.setCorePoolSize(5);
// 最大线程数:线程池最大的线程数,只有在缓冲队列满了之后才会申请超过核心线程数的线程
executor.setMaxPoolSize(20);
// 缓冲队列:用来缓冲执行任务的队列
executor.setQueueCapacity(500);
// 允许线程的空闲时间60秒:当超过了核心线程之外的线程在空闲时间到达之后会被销毁
executor.setKeepAliveSeconds(60);
// 线程池名的前缀:设置好了之后可以方便我们定位处理任务所在的线程池
executor.setThreadNamePrefix("线程名称前缀-");
// 缓冲队列满了之后的拒绝策略:由调用线程处理(一般是主线程)
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.DiscardPolicy());
executor.initialize();
return executor;
}
}
使用子线程执行任务
/**
* 更新摸鱼列表
*/
@Async("commonExecutor")
public void xxxTask() {
}
这个方法所在的类,要跟调用这个方法的类是不同一个类,否则xxxTask跟调用的地方是同一个线程。
注意事项
子线程执行的方法不可以跟调用的地方在同一个类,否则无效。