CompletableFuture 简单与链式的区别？

导读：从 JDK 8 开始，在 Concurrent 包中提供了一个强大的异步编程工具 CompletableFuture。在 JDK8 之前，异步编程可以通过线程池和 Future 来实现，但功能还不够强大。CompletableFuture 的出现，使 Java 的异编程能力向前迈进了一大步。在探讨 CompletableFuture 的原理之前，先详细看一下 CompletableFuture 的用法，从这些用法中，可以看到相较之前的 Future 有哪些能力得到了提升。

提交给 CompletableFuture 执行的任务 有四种类型：Runnable、Consumer、Supplier、Function。简单说明这四种任务原型的对比。

runAsync 与 supplierAsync 是 CompletableFutre 的静态方法；

而 thenAccept、thenAsync、thenApply 是 CompletableFutre 的成员方法 因为初始的时候没有 CompletableFuture 对象，也没有参数可传，所以提交的只能是 Runnable 或者 Supplier，只能是静态方法；

通过静态方法生成 CompletableFuture 对象之后，便可以链式地提交其他任务了，这个时候就可以提交 Runnable、Consumer、Function 且都是成员方法。下面主要结合一下案例来分析

最简单的用法

CompletableFuture 实现了 Future 接口，所以它也具有 Future 的特 性：调用 get() 方法会阻塞在那，直到结果返回。

另外 1 个线程调用 complete 方法完成该 Future，则所有阻塞在 get() 方法的线程都将获得返回结果。

提交任务：runAsync 与 supplyAsync

例 1：runAsync（Runnable）

上面的例子是一个空的任务，下面尝试提交一个真的任务，然后等待 果返回。

例 2：supplyAsync（Supplier）

CompletableFuture.runAsync（..）传入的是一个 Runnable 接口， 在上面的代码中是使用了 Java 8 的 lambda 表达式的写法，和定义一个 Runnable 对象是等价的。

例 2 和例 1 的区别在于，例 2 的任务有返回值。没有返回值的任务， 提交的是 Runnable，返回的是 CompletableFuture<Void>；有返 回值的任务，提交的是 Supplier，返回的是 CompletableFuture<String>；Supplier 和前面的 Callable 很相似。

通过上面两个例子可以看出，在基本的用法上，CompletableFuture 和 Future 很相似，都可以提交两类任务：一类是无返回值的，另一类是有 返回值的。

链式的 CompletableFuture：thenRun、thenAccept 和 thenApply

对于 Future，在提交任务之后，只能调用 get（）等结果返回；但对 于 CompletableFuture，可以在结果上面再加一个 callback，当得到结果 之后，再接着执行 callback。

例 1：thenRun（Runnable）

例 2：thenAccept（Consumer）

例 3：thenApply（Function）

三个例子都是在任务执行完成之后，再紧急执行一个 callback，只是 callback 的形式有所区别：

• thenRun 后面跟的是一个无参数、无返回值的方法，即 Runnable，所以最终的返回值是 CompletableFuture<Void>；类 型。

• thenAccept 后面跟的是一个有参数、无返回值的方法，称为 Consumer，返回值也是 CompletableFuture<Void>；类型。顾名 思义，只进不出，所以称为 Consumer；前面的 Supplier，是无参数，有 返回值，只出不进，和 Consumer 刚好相反。

• thenApply 后面跟的是一个有参数、有返回值的方法，称为 Function。返回值是 CompletableFuture<String>；类型。而参数接收的是前一个任务，即 supplyAsync（..）这个任务的返回 值。因此这里只能用 supplyAsync，不能用 runAsync。因为 runAsync 没有返回值，不能为下一个链式方法传入参数。

而参数接收的是前一个任务，即 supplyAsync（..）这个任务的返回 值。因此这里只能用 supplyAsync，不能用 runAsync。因为 runAsync 没有返回值，不能为下一个链式方法传入参数。