Springboot Async异步扩展使用结合 CompletableFuture

女爷i 2023-10-02 12:12 44阅读 0赞

# **前言** #

很早前，出过一篇介绍springboot怎么使用异步线程的文章（如果你还未了解异步的使用，可以先看看这篇）

> 《SpringBoot 最简单的使用异步线程案例 @Async》：
> 
> https://blog.csdn.net/qq\_35387940/article/details/83991594

然后近期有些小伙伴使用这个@Async的时候，私信我提出了一些业务场景，说需要拿返回值，但是又想结合‘异步’。

特别是调用第三方系统，怕耗时，不想调完一次再调一次。

其实，这种情形，就是一个典型的多线程处理场景。

在一个主线程上，分叉出几个异步线程执行不同的逻辑，再看情况是否需要拿回异步线程的返回数据。

**该篇文章，就是给大家带来基于@Async的使用，再结合 CompletableFuture 去实现我们刚提到的场景。**

事不宜迟，进入主题。

# **正文** #

结合实例，给大家去讲解，介绍**@Async的使用，再结合 CompletableFuture 的使用。**

## 需求场景：    ##

拉取第三方数据 ，分别需要拉取 A业务数据（需要2秒） 、拉取 B业务数据（需要2秒）、拉取 C业务数据（需要2秒） ，最后再一并返回给前端。

还涉及到了 超时调用的问题（项目要求每个接口不能超过 5秒 ），这时候就特别需要注意多线程的使用了。

![watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_20_color_FFFFFF_t_70_g_se_x_16][]

这种情形，我们就会想到使用 异步：  
  
![watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_20_color_FFFFFF_t_70_g_se_x_16 1][]

写过模拟的测试接口：  
  
![watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_12_color_FFFFFF_t_70_g_se_x_16][]

运行结果我们看一下:

![watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_20_color_FFFFFF_t_70_g_se_x_16 2][]

因为异步标记了三个方法，所以看到主线程时间没被受影响，但是同时返回值也拿不到。

**这样 耗时接近0秒, 但是返回给前端的数据就是 null了。**

**当前的执行简图：**

![watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_20_color_FFFFFF_t_70_g_se_x_16 3][]

OK，就是基于当前这个情况，我们开始加入 **CompletableFuture 的使用 。**

对代码进行改造一下：  
![watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_20_color_FFFFFF_t_70_g_se_x_16 4][]

调用模拟接口代码也需要跟着调整：  
  
![watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_17_color_FFFFFF_t_70_g_se_x_16][]

运行结果：  
  
![watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_17_color_FFFFFF_t_70_g_se_x_16 1][]

当前的执行简图：

![watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_20_color_FFFFFF_t_70_g_se_x_16 5][]

为什么耗时是2秒，帮助理解：

>     CompletableFuture.allOf(a,b,c).join();
>     我们这里 allOf 传递了 三个 异步线程的返回值， 所以看到上图，也就出现了三个等待返回值的坑位 A B C。
> 
> 可以把这个想象成一辆车，三个位， 必须人满才发车。
> 
> 那么要等多久呢？  
> 这三个人几乎是同时走向这辆车的，但是无论其他人走多快，因为得整整齐齐，所以
> 
> 耗时取决于这三个坑位，最慢上车的那个人。

再次验证：

直接把pullDataA 改为等待8秒 ，  
  
![watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_20_color_FFFFFF_t_70_g_se_x_16 6][]

运行结果：

耗时 8秒

![watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_16_color_FFFFFF_t_70_g_se_x_16][]

额外啰唆一下：

看到这，各位看官应该是都掌握怎么去使用操作 CompletableFuture 了。

只要我想要某个异步线程的返回值，我就把这个方法返回接收值CompletableFuture 加入到 **allOf 里面去 。**

对，这么使用确实是ok的。

其实，只要你使用到了 返回接收值CompletableFuture ，其实就已经开始触发，并不是一定要用allOf。

举例说明：

ps：那么我们怎么去使用这个CompletableFuture ，大家应该多少会玩了吧。

![watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_20_color_FFFFFF_t_70_g_se_x_16 7][]

再啰唆一下，  
  
  
其实我的这个打印输出，

System.out.println(a.get()+b.get()+c.get());

里面也调用了get（） ，也就是也算是使用了。

那么再举一个小例子：  
![watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_19_color_FFFFFF_t_70_g_se_x_16][]

这种情况，我们使用了 CompletableFuture<String>分别去接收返回值，但是我们后面没去使用操作它们，也没使用allOf ， 看下运行结果：  
  
![watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_20_color_FFFFFF_t_70_g_se_x_16 8][]

也就是说，这种情况，不会因为 我们使用了 CompletableFuture 而促使让主线程去等待任何异步线程。

OK，该篇就到这吧。

[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_20_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/c39e7b89d7f441378f6d1ad33188814b.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_20_color_FFFFFF_t_70_g_se_x_16 1]: https://img-blog.csdnimg.cn/c444b61e014b474d9cc8c7cf25bfccbf.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_12_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/4b099d1567c74106b2f3e815a5f7eba2.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0,size_12,color_FFFFFF,t_70,g_se,x_16
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_20_color_FFFFFF_t_70_g_se_x_16 2]: https://img-blog.csdnimg.cn/1a2d5de73f9545dea5e832ff1dc8899c.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_20_color_FFFFFF_t_70_g_se_x_16 3]: https://img-blog.csdnimg.cn/59bc86921a834daab672fd5bfd845e33.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_20_color_FFFFFF_t_70_g_se_x_16 4]: https://img-blog.csdnimg.cn/5fc7b24bcd5a4ff79fa689cfff7f59ca.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_17_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/22f801f97da34d57b1ad367dd6c9dde3.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0,size_17,color_FFFFFF,t_70,g_se,x_16
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_17_color_FFFFFF_t_70_g_se_x_16 1]: https://img-blog.csdnimg.cn/fb0c1c94fcea4bdb90c3637cd415162f.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0,size_17,color_FFFFFF,t_70,g_se,x_16
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_20_color_FFFFFF_t_70_g_se_x_16 5]: https://img-blog.csdnimg.cn/720d034dd3374f71998fa17e77a9bc54.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_20_color_FFFFFF_t_70_g_se_x_16 6]: https://img-blog.csdnimg.cn/5514e89be62c43aca868396ff82e84ac.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_16_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/76609812d2e840879039bf8f9d817c22.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0,size_16,color_FFFFFF,t_70,g_se,x_16
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_20_color_FFFFFF_t_70_g_se_x_16 7]: https://img-blog.csdnimg.cn/d23fce22ea754433958a905be96975ff.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_19_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/6a49e939396141c297fe95dd4286e2cd.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0,size_19,color_FFFFFF,t_70,g_se,x_16
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_20_color_FFFFFF_t_70_g_se_x_16 8]: https://img-blog.csdnimg.cn/19d4363cb7e34931a360fd18da794b84.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0,size_20,color_FFFFFF,t_70,g_se,x_16