Spring Boot中使用@Async的时候,千万别忘了线程池的配置!
上一篇我们介绍了如何使用@Async
注解来创建异步任务,我可以用这种方法来实现一些并发操作,以加速任务的执行效率。但是,如果只是如前文那样直接简单的创建来使用,可能还是会碰到一些问题。存在有什么问题呢?先来思考下,下面的这个接口,通过异步任务加速执行的实现,是否存在问题或风险呢?
@RestController
public class HelloController {@Autowired
private AsyncTasks asyncTasks;
@GetMapping("/hello")
public String hello() {
// 将可以并行的处理逻辑,拆分成三个异步任务同时执行
CompletableFuture task1 = asyncTasks.doTaskOne();
CompletableFuture task2 = asyncTasks.doTaskTwo();
CompletableFuture task3 = asyncTasks.doTaskThree();
CompletableFuture.allOf(task1, task2, task3).join();
return "Hello World";
}
}
虽然,从单次接口调用来说,是没有问题的。但当接口被客户端频繁调用的时候,异步任务的数量就会大量增长:3 x n(n为请求数量),如果任务处理不够快,就很可能会出现内存溢出的情况。那么为什么会内存溢出呢?根本原因是由于Spring Boot默认用于异步任务的线程池是这样配置的:
【Spring Boot中使用@Async的时候,千万别忘了线程池的配置!】
文章图片
图中我标出的两个重要参数是需要关注的:
queueCapacity
:缓冲队列的容量,默认为INT的最大值(2的31次方-1)。maxSize
:允许的最大线程数,默认为INT的最大值(2的31次方-1)。
配置默认线程池 默认线程池的配置很简单,只需要在配置文件中完成即可,主要有以下这些参数:
spring.task.execution.pool.core-size=2
spring.task.execution.pool.max-size=5
spring.task.execution.pool.queue-capacity=10
spring.task.execution.pool.keep-alive=60s
spring.task.execution.pool.allow-core-thread-timeout=true
spring.task.execution.shutdown.await-termination=false
spring.task.execution.shutdown.await-termination-period=
spring.task.execution.thread-name-prefix=task-
具体配置含义如下:
spring.task.execution.pool.core-size
:线程池创建时的初始化线程数,默认为8spring.task.execution.pool.max-size
:线程池的最大线程数,默认为int最大值spring.task.execution.pool.queue-capacity
:用来缓冲执行任务的队列,默认为int最大值spring.task.execution.pool.keep-alive
:线程终止前允许保持空闲的时间spring.task.execution.pool.allow-core-thread-timeout
:是否允许核心线程超时spring.task.execution.shutdown.await-termination
:是否等待剩余任务完成后才关闭应用spring.task.execution.shutdown.await-termination-period
:等待剩余任务完成的最大时间spring.task.execution.thread-name-prefix
:线程名的前缀,设置好了之后可以方便我们在日志中查看处理任务所在的线程池
chapter7-5
的结果来进行如下操作。首先,在没有进行线程池配置之前,可以先执行一下单元测试:
@Test
public void test1() throws Exception {
long start = System.currentTimeMillis();
CompletableFuture task1 = asyncTasks.doTaskOne();
CompletableFuture task2 = asyncTasks.doTaskTwo();
CompletableFuture task3 = asyncTasks.doTaskThree();
CompletableFuture.allOf(task1, task2, task3).join();
long end = System.currentTimeMillis();
log.info("任务全部完成,总耗时:" + (end - start) + "毫秒");
}
由于默认线程池的核心线程数是8,所以3个任务会同时开始执行,日志输出是这样的:
2021-09-15 00:30:14.819INFO 77614 --- [task-2] com.didispace.chapter76.AsyncTasks: 开始做任务二
2021-09-15 00:30:14.819INFO 77614 --- [task-3] com.didispace.chapter76.AsyncTasks: 开始做任务三
2021-09-15 00:30:14.819INFO 77614 --- [task-1] com.didispace.chapter76.AsyncTasks: 开始做任务一
2021-09-15 00:30:15.491INFO 77614 --- [task-2] com.didispace.chapter76.AsyncTasks: 完成任务二,耗时:672毫秒
2021-09-15 00:30:19.496INFO 77614 --- [task-3] com.didispace.chapter76.AsyncTasks: 完成任务三,耗时:4677毫秒
2021-09-15 00:30:20.443INFO 77614 --- [task-1] com.didispace.chapter76.AsyncTasks: 完成任务一,耗时:5624毫秒
2021-09-15 00:30:20.443INFO 77614 --- [main] c.d.chapter76.Chapter76ApplicationTests: 任务全部完成,总耗时:5653毫秒
接着,可以尝试在配置文件中增加如下的线程池配置
spring.task.execution.pool.core-size=2
spring.task.execution.pool.max-size=5
spring.task.execution.pool.queue-capacity=10
spring.task.execution.pool.keep-alive=60s
spring.task.execution.pool.allow-core-thread-timeout=true
spring.task.execution.thread-name-prefix=task-
日志输出的顺序会变成如下的顺序:
2021-09-15 00:31:50.013INFO 77985 --- [task-1] com.didispace.chapter76.AsyncTasks: 开始做任务一
2021-09-15 00:31:50.013INFO 77985 --- [task-2] com.didispace.chapter76.AsyncTasks: 开始做任务二
2021-09-15 00:31:52.452INFO 77985 --- [task-1] com.didispace.chapter76.AsyncTasks: 完成任务一,耗时:2439毫秒
2021-09-15 00:31:52.452INFO 77985 --- [task-1] com.didispace.chapter76.AsyncTasks: 开始做任务三
2021-09-15 00:31:55.880INFO 77985 --- [task-2] com.didispace.chapter76.AsyncTasks: 完成任务二,耗时:5867毫秒
2021-09-15 00:32:00.346INFO 77985 --- [task-1] com.didispace.chapter76.AsyncTasks: 完成任务三,耗时:7894毫秒
2021-09-15 00:32:00.347INFO 77985 --- [main] c.d.chapter76.Chapter76ApplicationTests: 任务全部完成,总耗时:10363毫秒
- 任务一和任务二会马上占用核心线程,任务三进入队列等待
- 任务一完成,释放出一个核心线程,任务三从队列中移出,并占用核心线程开始处理
注意:这里可能有的小伙伴会问,最大线程不是5么,为什么任务三是进缓冲队列,不是创建新线程来处理吗?这里要理解缓冲队列与最大线程间的关系:只有在缓冲队列满了之后才会申请超过核心线程数的线程来进行处理。所以,这里只有缓冲队列中10个任务满了,再来第11个任务的时候,才会在线程池中创建第三个线程来处理。这个这里就不具体写列子了,读者可以自己调整下参数,或者调整下单元测试来验证这个逻辑。本系列教程《Spring Boot 2.x基础教程》点击直达!,欢迎收藏与转发!如果学习过程中如遇困难?可以加入我们Spring技术交流群,参与交流与讨论,更好的学习与进步!
代码示例 本文的完整工程可以查看下面仓库中
2.x
目录下的chapter7-6
工程:- Github:https://github.com/dyc87112/SpringBoot-Learning/
- Gitee:https://gitee.com/didispace/SpringBoot-Learning/
Star
支持,您的关注是我坚持的动力!欢迎关注我的公众号:程序猿DD,分享其他地方看不到的知识与思考
推荐阅读
- 热闹中的孤独
- Shell-Bash变量与运算符
- JS中的各种宽高度定义及其应用
- 2021-02-17|2021-02-17 小儿按摩膻中穴-舒缓咳嗽
- 深入理解Go之generate
- 异地恋中,逐渐适应一个人到底意味着什么()
- Activiti(一)SpringBoot2集成Activiti6
- 我眼中的佛系经纪人
- 《魔法科高中的劣等生》第26卷(Invasion篇)发售
- “成长”读书社群招募