【玩转SpringBoot】异步任务执行与其线程池配置

本文公众号来源：编程新说

作者：编程新说李新杰

本文已收录至我的GitHub

同步代码写起来简单，但就是怕遇到耗时操作，会影响效率和吞吐量。 此时异步代码才是王者，但涉及多线程和线程池，以及异步结果的获取，写起来颇为麻烦。 不过在遇到SpringBoot异步任务时，这个问题就不存在了。因为Spring家族是最替用户考虑的。 结果就是，像同步一样简单，像异步一样强大。 众所熟悉的同步代码 先准备一些代码，为了模拟耗时操作，在其中加入线程睡眠语句。 同时打印出运行这些代码的线程信息。如下图01：

其中一个是没有返回值的，一个是有返回值的。 然后把它注入到另一个类里进行调用，在调用时也输出一下主线程信息。如下图02：

下面是输出结果，如下图03：

可以看到这些代码运行在主线程中，所以这些代码的耗时操作会影响主线程。 首选的方案就是把耗时操作放入另一个线程中执行（通常称为工作线程），把主线程解放出来。 同步代码的异步化改造 由于SpringBoot已经帮我们做好了一切，只需按要求改造即可，只需两步，真的是非常简单。 第一步，引入启用异步任务的注解，@EnableAsync，如下图04：

第二步，在原来的方法上标上@Async注解，如下图05：

这就好了，然后像普通方法一样调用，如下图06：

看下输出结果，如下图07：

可以看到主线程的id是1，而且瞬间执行完。任务在另一个线程id为17的线程中执行，且等耗时操作执行完后才结束。 代码完全不变，只需加两个注解，同步立马变成异步啦。简直爽歪歪了。 主要是因为这个方法没有返回值，如果有的话，只需改下返回类型即可。 SpringBoot一共支持三种返回类型，来逐一看下。 第一种，返回类型为Java的Future<?>，如下图08：

熟悉Java多线程的朋友对这个类都应该不陌生。为了代码能正常编译，在方法最后需要return一个这样的类型。 在同步代码中，我们原来return的是一个Object类型，显然不满足需求，所以SpringBoot就想了一个办法。 新增了一个类，AsyncResult，使用它进行类型适配，这也是此类的主要作用，保证编译通过。 这个类就像一个“类型”占位符一样，如果你真正了解Java多线程的话就会明白，否则绝对不明白。 然后就像普通方法调用一样调用它，接着通过while循环等待异步任务完成后，输出返回结果。 注意，我特意输出了一下方法调用返回的future变量，如下图09：

输出结果如下图10：

可以看到任务是在线程id为17的线程中执行，主线程不断睡眠等待，直到任务完成后才获取到任务的返回结果。 重要时刻来临，可以看到我们输出的future变量类型是Java的FutureTask类，而我们实际在代码中return的是Spring的AsyncResult类。 是不是很奇怪呢？其实一点都不怪，这和Java多线程有关，如果还不明白的话，后面有说明。 第二种，返回类型为Spring的ListenableFuture<?>，如下图11：

可以看到代码在return的时候写法是一样的，那这个类型的好处是什么呢？答案是可以注册回调。 有了回调，任务在完成后会自动执行回调代码，所以主线程就不用等了。 因此在调用时要注册回调代码，包括成功回调和失败回调，如下图12：

注意，我们同样打印一下方法返回变量listenableFuture的类型。 输出结果如下图13：

可以看到此时主线程瞬间执行完毕。任务在线程id为17的线程中执行，完成后执行了回调，且在同一个线程中。 同样变量listenableFuture的类型是Spring的ListenableFutureTask类，并不是我们在代码里return的AsyncResult类。 第三种，返回类型为Java的CompletableFuture<?>，如下图14：

这个类型是Java 8新增的，可以对异步任务进行特殊的操作。 然后进行调用，同样输出下返回变量类型，如下图15：

输出结果如下图16：

输出内容很容易看懂。重点看下返回变量的类型，它就是Java的CompletableFuture<?>类。 那我们在代码中return的是什么类型呢？如下图17：

可以看到和真实调用时返回的还是不一样。如果还不明白，下面来说明下。 Spring在遇到标有@Async的方法时会生成代理，代理做的事情就是把该方法包装成一个任务submit到线程池中。 在submit的时候会返回真正的返回值，就是上面我们在调用方法时输出的。 而我们在写@Async方法代码时return的是一个类似类型占位符的类，它的一个作用就是保证编译通过。 另一个作用就是传递返回值，在任务执行完成时，把值往外层传递。 线程池的个性化按需配置 对于Java来说，几乎所有的异步执行代码都是提交到线程池中来执行的，因为线程池可以管理好线程，我们就不用操心了。 不过我们依然可以对线程池进行配置，如核心线程数、最大线程数、内部队列长度等等。 SpringBoot当然也支持这些配置，按照惯例，这些配置也是放在application.yml配置文件中的。 一些IDE是可以进行自动提示的，如下图18：

这些配置的前缀是spring.task.execution，主要包括三类配置，线程池中线程的数目和队列的大小，线程池关闭时的行为，线程名称的前缀。 有求知欲的朋友可能会寻思，这些配置究竟是如何生效的呢？下面就来满足一下好奇心，其实很简单。 SpringBoot的特性之一就是自动配置，这些自动配置代码都位于这个jar包中，如下图19：

这个jar包名称很容易记住，所以最好都能记住，下次有疑问自己就可以去找了。 我们在这个jar包里寻找和任务（task）相关的包名称，如下图20：

前两个类是和任务执行相关的，其中以Properties结尾的类是用于存放application.yml里面的配置的。 以AutoConfiguration结尾的类是用于自动配置的，主要是bean定义的注册。 这种写法是SpringBoot自动配置的标准模式，可以看看其它的，都是这样的。 看下TaskExecutionProperties类，如下图21：

指定好前缀后，配置文件中的配置项和类中的属性完全是一一对应的，而且类中属性可以有默认值，这样配置文件中没有配置时就使用默认值。 再来看下TaskExecutionAutoConfiguration类，这里面就注册了两个bean，如下图22：

首先使用刚刚的属性注册一个TaskExecutorBuilder类型的bean，然后再使用它注册一个ThreadPoolTaskExecutor类型的bean。 其实异步任务执行主要是要找到一个线程池的bean，来完成任务的提交，具体寻找逻辑的如下： 1）如果容器中存在唯一一个TaskExecutor类型的bean，那就用它。否则继续往下。 2）如果容器中存在一个名称为taskExecutor且类型为Executor的bean，就用它，否则继续往下。 3）将使用SimpleAsyncTaskExecutor类进行异步方法调用。 void异步方法的异常处理 需要注意的是，返回类型为void的异步方法，将不会向调用者传递异常。默认情况下，这些未捕获的异常仅仅输出一下日志。 所以对于void方法一定要自己处理好异常。如果恰巧没处理好，怎么办呢？不要着急。 SpringBoot提供了统一的未捕获异常处理方式，只要实现一个接口即可，如下图23：

我们可以获取到抛出的异常，还有抛出异常时执行的异步方法，还有调用该异步方法时传入的参数。 那么，对于有返回值的异步方法，则本身可以传递异常，所以不会使用这种方式。这一点需注意。 作者寄语 异步方法的原理很简单，就是在单独的线程中执行一个方法或代码片段。 不过有两方面需要注意，技术方面和业务方面： 技术方面： 1）如何获取异步方法的返回值 2）如何处理异步方法产生的异常 3）如何处理异步方法超时的问题 业务方面: 1）异步方法执行成功时对业务的影响 2）异步方法抛出异常时对业务的影响 3）异步方法执行超时时对业务的影响