CompletableFuture基本用法

异步计算

• 所谓异步调用其实就是实现一个可无需等待被调用函数的返回值而让操做继续运行的方法。在 Java 语言中，简单的讲就是另启一个线程来完成调用中的部分计算，使调用继续运行或返回，而不须要等待计算结果。但调用者仍须要取线程的计算结果。

• JDK5新增了Future接口，用于描述一个异步计算的结果。虽然 Future 以及相关使用方法提供了异步执行任务的能力，可是对于结果的获取倒是很不方便，只能经过阻塞或者轮询的方式获得任务的结果。阻塞的方式显然和咱们的异步编程的初衷相违背，轮询的方式又会耗费无谓的 CPU 资源，并且也不能及时地获得计算结果。

• 之前咱们获取一个异步任务的结果多是这样写的

　　

Future 接口的局限性

Future接口能够构建异步应用，但依然有其局限性。它很难直接表述多个Future 结果之间的依赖性。实际开发中，咱们常常须要达成如下目的：

1. 将多个异步计算的结果合并成一个

2. 等待Future集合中的全部任务都完成

3. Future完成事件（即，任务完成之后触发执行动做）

4. 。。。

函数式编程

CompletionStage

• CompletionStage表明异步计算过程当中的某一个阶段，一个阶段完成之后可能会触发另一个阶段

• 一个阶段的计算执行能够是一个Function，Consumer或者Runnable。好比：stage.thenApply(x -> square(x)).thenAccept(x -> System.out.print(x)).thenRun(() -> System.out.println())

• 一个阶段的执行多是被单个阶段的完成触发，也多是由多个阶段一块儿触发

CompletableFuture

• 在Java8中，CompletableFuture提供了很是强大的Future的扩展功能，能够帮助咱们简化异步编程的复杂性，而且提供了函数式编程的能力，能够经过回调的方式处理计算结果，也提供了转换和组合 CompletableFuture 的方法。
• 它可能表明一个明确完成的Future，也有可能表明一个完成阶段（ CompletionStage ），它支持在计算完成之后触发一些函数或执行某些动做。
• 它实现了Future和CompletionStage接口

　　

CompletableFuture基本用法

建立CompletableFuture

thenApply

当前阶段正常完成之后执行，并且当前阶段的执行的结果会做为下一阶段的输入参数。thenApplyAsync默认是异步执行的。这里所谓的异步指的是不在当前线程内执行。

thenApply至关于回调函数（callback）

---

 

thenAccept与thenRun

• 能够看到，thenAccept和thenRun都是无返回值的。若是说thenApply是不停的输入输出的进行生产，那么thenAccept和thenRun就是在进行消耗。它们是整个计算的最后两个阶段。

• 一样是执行指定的动做，一样是消耗，两者也有区别：

  • thenAccept接收上一阶段的输出做为本阶段的输入 　　

  • thenRun根本不关心前一阶段的输出，根本不不关心前一阶段的计算结果，由于它不须要输入参数

thenCombine整合两个计算结果

例如，此阶段与其它阶段一块儿完成，进而触发下一阶段：

whenComplete

 

最后，举个栗子：

事实上，若是每一个操做都很简单的话（好比：上面的例子中按照id去查）没有必要用这种多线程异步的方式，由于建立线程还须要时间，还不如直接同步执行来得快。

事实证实，只有当每一个操做很复杂须要花费相对很长的时间（好比，调用多个其它的系统的接口；好比，商品详情页面这种须要从多个系统中查数据显示的）的时候用CompletableFuture才合适，否则区别真的不大，还不如顺序同步执行。