CompletableFuture

Posted 2022-12-03 再等三分钟

要说CompletableFuture，就要先知道Future接口。

Future是Java5中添加的类，用来描述一个异步计算的结果。你可以轮询isDone方法检查计算是否完成，或者使用get阻塞住调用线程，直到计算完成返回结果，但是这个get()方法会阻塞住调用线程，这种阻塞的方式显然和我们的异步编程的初衷相违背。你也可以使用cancel方法停止任务的执行。Java 5并发包主要聚焦于异步任务处理，其模型特点是基于一个生产者线程，不断地创造任务，通过一个堵塞Blocking队列传递给任务的消费者。

Java 8的CompletableFuture背后也是依靠fork/join框架启动新的线程实现异步与并发的，一般情况下，我们将一个任务放到另外一个线程执行，可能就无需等待那个线程处理完成的结果，而是直接在主线程中返回完成，但是有一些业务恰是需要等待新启动的线程中任务完成，然后和当前主线程中的处理进行合并再处理.

public static CompletableFuture<Void> runAsync(Runnable runnable) public static CompletableFuture<Void> runAsync(Runnable runnable, Executor executor) public static <U> CompletableFuture<U> supplyAsync(Supplier<U> supplier) public static <U> CompletableFuture<U> supplyAsync(Supplier<U> supplier, Executor executor

2 3 4

public static CompletableFuture<Void> runAsync(Runnable runnable) public static CompletableFuture<Void> runAsync(Runnable runnable, Executor executor) public static <U> CompletableFuture<U> supplyAsync(Supplier<U> supplier) public static <U> CompletableFuture<U> supplyAsync(Supplier<U> supplier, Executor executor

以Async结尾并且没有指定Executor的方法会使用ForkJoinPool.commonPool()作为它的线程池执行异步代码。

runAsync方法也好理解，它以Runnable函数式接口类型为参数，所以CompletableFuture的计算结果为空。

supplyAsync方法以Supplier<U>函数式接口类型为参数,CompletableFuture的计算结果类型为U。

2 3 4

public static CompletableFuture<Void> runAsync(Runnable runnable) public static CompletableFuture<Void> runAsync(Runnable runnable, Executor executor) public static <U> CompletableFuture<U> supplyAsync(Supplier<U> supplier) public static <U> CompletableFuture<U> supplyAsync(Supplier<U> supplier, Executor executor