7-线程池隔离，异步编排,分布式信号量

在我们后来的开发中有很多异步场景，为了提高系统的吞吐量和运行时间，我们要做一些异步任务；异步我们都是使用Java里面的Thread开启线程的任务方式。

在分布式架构中，我们还有一个需要解决的复杂任务场景，比如A,B,C三个异步任务进行运行，C必须等待A运行完的返回结果后才可以运行，B又不用等A,C我们可以直接异步运行，我们要编排好他们的业务进行异步调用又是一个复杂的过程。我们就可以使用CompletableFuture来解决这个问题

CompletableFuture

1、启动异步任务

CompletableFuture提供了四个静态方法来创建一个异步操作。

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)

1. runXxxx都是没有返回结果，supplyXxx都是可以获取返回结果的
2. 可以传入自定义的线程池，否则就用默认的线程池。

2、完成回调与异常感知

public CompletableFuture<T> whenComplete(BiConsumer<? super T, ? super Throwable> action) 
public CompletableFuture<T> whenCompleteAsync(BiConsumer<? super T, ? super Throwable> action)
public CompletableFuture<T> whenCompleteAsync(BiConsumer<? super T, ? super Throwable> action, Executor executor)

public CompletableFuture<T> exceptionally(Function<Throwable, ? extends T> fn)

whenComplete可以处理正常和异常的计算结果，exceptionally处理异常情况。

whenComplete和whenCompleteAsync的区别：

• whenComplete是按当前任务的线程继续执行whenComplete的任务。
• whenCompleteAsync是把这个任务提交给线程池来进行执行。

方法不以Async结尾，意味着Action使用相同的线程执行，而Async可能会使其他线程执行（如果是使用线程池，可能也会被同一个线程池选中执行）

3、handle最终处理

public <U> CompletableFuture<U> handle(BiFunction<? super T, Throwable, ? extends U> fn) 
public <U> CompletableFuture<U> handleAsync(BiFunction<? super T, Throwable, ? extends U> fn)
public <U> CompletableFuture<U> handleAsync(BiFunction<? super T, Throwable, ? extends U> fn, Executor executor) 

和complete一样，可对结果做最后的处理（可处理异常），可改变返回值。

4、线程串行化

• thenApply方法：当一个线程依赖另一个线程时，获取是一个任务返回的结果，并返回当前任务的返回值。
• thenAccept方法：消费处理结果。接收任务的处理结果。并消费处理，无返回结果。
• thenRun方法: 只要上面的任务执行完成，就开始thenRun，不关心前一阶段的输出，也不关心前一阶段的计算结果，因为它不需要输入参数

如果说thenApply是不停的输入输出的进行生产，那么thenAccept和thenRun就是在进行消耗。它们是整个计算的最后两个阶段。

以上都要前置任务成功完成，带有Async默认是异步执行的。

5、任务组合

两个任务必须都完成，触发该任务：

• thenCombine：组合两个future，获取两个future的返回结果，并返回当前任务的返回值
• thenAcceptBoth：组合两个future，获取两个future任务的返回结果，然后处理任务，没有返回值。
• runAfterBoth：组合两个future，不需要获取future的结果，只需要两个future处理完任务后，处理该任务。

两个任务其中一个完成，触发该任务：

• applyToEither：获取他们的返回值，处理任务并有新的返回值。
• acceptEither：获取他们的返回值，处理任务，没有新的返回值。
• runAfterEither：不需要获取future的结果，处理任务，也没有返回值。

多任务组合：

• allOf：等待所有任务完成
• anyOf:只要有一个任务完成