开发中我们经常会用到异步方法调用，具体到代码层面，异步方法调用的实现方式有很多种，比如最原始的通过实现Runnable接口或者继承Thread类创建异步线程，然后启动异步线程；再如，可以直接用java.util.concurrent包提供的线程池相关API实现异步方法调用。
如果说可以用一行代码快速实现异步方法调用，那是不是比上面方法香很多。
Spring提供了Async注解，就可以帮助我们一行代码搞定异步方法调用。Async注解用起来是很爽，但是如果不对其底层实现做深入研究，难免有时候也会心生疑虑，甚至会因使用不当，遇见一些让人摸不着头脑的问题。
本文首先将对Async注解做简单介绍，然后和大家分享一个我们项目中因Async注解使用不当的线上问题，接着再深扒Spring源码，对Async注解底层异步线程池的实现原理一探究竟。
图片
从源码可以看出@Async注解定义很简单，只需要关注两点：
Async注解异步调用实现原理概述
在Spring框架中，Async注解的实现是通过AOP来实现的。具体来说，Async注解是由AsyncAnnotationAdvisor这个切面类来实现的。
AsyncAnnotationAdvisor类是Spring框架中用于处理Async注解的切面，它会在被Async注解标识的方法被调用时，创建一个异步代理对象来执行方法。这个异步代理对象会在一个新的线程中调用被@Async注解标识的方法，从而实现方法的异步执行。
在AsyncAnnotationAdvisor中，会使用AsyncExecutionInterceptor来处理Async注解。AsyncExecutionInterceptor是实现了MethodInterceptor接口的类，用于拦截被Async注解标识的方法的调用，并在一个新的线程中执行这个方法。
通过AOP的方式实现Async注解的异步执行，Spring框架可以在方法调用时动态地创建代理对象来实现异步执行，而不需要在业务代码中显式地创建新线程。
总的来说，Async注解的实现是通过AOP机制来实现的，具体的切面类是AsyncAnnotationAdvisor，它利用AsyncExecutionInterceptor来处理被Async注解标识的方法的调用，实现方法的异步执行。
进入到Spring源码Async注解AOP切面实现部分，我们重点剖析异步调用实现中线程池是怎么处理的。下图是org.springframework.aop.interceptor.AsyncExecutionInterceptor#invoke方法的实现，可以看出是调用determineAsyncExecutor方法获取异步线程池。
AsyncExecutionInterceptor#invoke
下图是determineAsyncExecutor方法实现：
图片
图片
左图为AsyncExecutionInterceptor#determineAsyncExecutor，右图为AsyncExecutionAspectSupport#getExecutorQualifier
从代码实现中可以看到determineAsyncExecutor获取线程池的大致流程：
determineAsyncExecutor获取线程池流程
如果在使用Async注解时指定了自定义线程池比较好理解，如果使用Async注解时没有指定自定义线程池，Spring是怎么处理默认线程池呢？继续深入源码看看Spring提供的默认线程池的实现。
Async注解默认线程池有下面两个方法实现：
AsyncExecutionInterceptor#getDefaultExecutor
可以看出AsyncExecutionInterceptor#getDefaultExecutor方法比较简单：先尝试调用父类AsyncExecutionAspectSupport#getDefaultExecutor方法获取线程池，如果父类方法获取不到线程池再用创建SimpleAsyncTaskExecutor对象作为Async的线程池返回。
AsyncExecutionAspectSupport#getDefaultExecutor
再来看父类AsyncExecutionAspectSupport#getDefaultExecutor方法的实现，可以看到Spring根据类型从Spring容器中获取TaskExecutor类的实例，先记住这个关键点。
我们知道，Spring根据类型获取实例时，如果spring容器中有且只有一个指定类型的实例对象，会直接返回，否则的话，会抛出NoUniqueBeanDefinitionException异常或者NoSuchBeanDefinitionException异常。
但是，对于Executor类型，Spring容器却“网开一面”，有一个特殊处理：当从Spring容器中获取Executor实例对象时，如果满足@ConditionalOnMissingBean(Executor.class)条件，Spring容器会自动装载一个ThreadPoolTaskExecutor实例对象，而ThreadPoolTaskExecutor是TaskExecutor的实现类。
图片
图片
左图为TaskExecutionAutoConfiguration，右图为TaskExecutionProperties
从TaskExecutionProperties和TaskExecutionAutoConfiguration两个配置类我们看到Spring自动装载的ThreadPoolTaskExecutor线程池对象的参数：核心线程数=8；最大线程数=Integer.MAX_VALUE；队列大小=Integer.MAX_VALUE。
现在Async注解线程池源码已经看的差不多了，下面这张图是Spring处理Async异步线程池的流程：
Async异步线程池获取流程
归纳一下：如果在使用Async注解时没有指定自定义的线程池会出现以下几种情况：
本文链接：http://www.28at.com/showinfo-26-93708-0.html浅析Spring中Async注解底层异步线程池原理
声明：本网页内容旨在传播知识，若有侵权等问题请及时与本网联系，我们将在第一时间删除处理。邮件：2376512515@qq.com
Copyright © 2016-2023 天津谷骐科技有限公司 版权所有 sitemap.xml
违法及侵权请联系：2376512515@qq.com 津ICP备18001702号
津公网安备 12010102000574号
