Spring Boot @Async 默认线程池的问题

我就是我 2021-06-10 20:39 904阅读 0赞

@Async异步方法默认使用Spring创建ThreadPoolTaskExecutor。默认核心线程数：8，最大线程数：Integet.MAX\_VALUE，队列使用LinkedBlockingQueue，容量是：Integet.MAX\_VALUE，空闲线程保留时间：60s，线程池拒绝策略：AbortPolicy。

@Async异步方法默认使用Spring创建ThreadPoolTaskExecutor(参考TaskExecutionAutoConfiguration),

其中默认核心线程数为8, 默认最大队列和默认最大线程数都是Integer.MAX\_VALUE. 创建新线程的条件是队列填满时, 而

这样的配置队列永远不会填满, 如果有@Async注解标注的方法长期占用线程(比如HTTP长连接等待获取结果),

在核心8个线程数占用满了之后, 新的调用就会进入队列, 外部表现为没有执行.

可以手动配置相应属性：

#核心线程数
    spring.task.execution.pool.core-size=200
    #最大线程数
    spring.task.execution.pool.max-size=1000
    #空闲线程保留时间
    spring.task.execution.pool.keep-alive=3s
    #队列容量
    spring.task.execution.pool.queue-capacity=1000
    #线程名称前缀
    spring.task.execution.thread-name-prefix=test-thread-

配置类是TaskExecutionProperties【org.springframework.boot.autoconfigure.task.TaskExecutionProperties】

![format_png][]

![format_png 1][]

![format_png 2][]

现象:

1. 表面现象: 方法中输出的日志, 日志文件中找不到, 也没有任何报错(即@Async标注的方法没有执行, 也没有报错)

2. 分析现象: 日志中某个时刻之后没有了task-xxx线程的日志

原因:

@Async异步方法默认使用Spring创建ThreadPoolTaskExecutor(参考TaskExecutionAutoConfiguration),

其中默认核心线程数为8, 默认最大队列和默认最大线程数都是Integer.MAX\_VALUE. 创建新线程的条件是队列填满时, 而

这样的配置队列永远不会填满, 如果有@Async注解标注的方法长期占用线程(比如HTTP长连接等待获取结果),

在核心8个线程数占用满了之后, 新的调用就会进入队列, 外部表现为没有执行.

解决:

手动配置相应属性即可. 比如

spring.task.execution.pool.queueCapacity=4

spring.task.execution.pool.coreSize=20

备注:

此处没有配置maxSize, 仍是默认的Integer.MAX\_VALUE. 如果配置的话, 请考虑达到最大线程数时的处理策略(JUC包查找RejectedExecutionHandler的实现类)

(默认为拒绝执行AbortPolicy, 即抛出异常)

AbortPolicy: 直接抛出java.util.concurrent.RejectedExecutionException异常

CallerRunsPolicy: 主线程直接执行该任务，执行完之后尝试添加下一个任务到线程池中，可以有效降低向线程池内添加任务的速度

DiscardOldestPolicy: 抛弃旧的任务

DiscardPolicy: 抛弃当前任务

截图:

1. ThreadPoolTaskExecutor

2. SpringMonitor的配置属性

3. SpringMonitor的Threads

[format_png]: /images/20210527/b2051373565146849ce1e35e2afd1f66.png
[format_png 1]: /images/20210527/565e12d4b68a412d9d52619296a4acb7.png
[format_png 2]: /images/20210527/a9462f720f294ac0aa50a30e3121c34f.png