多线程异步编排CompletableFuture和CompletionStage

        异步调用实现一个不需要被等等的方法的返回值&＃xff1b;让调用者继续执行&＃xff08;异步执行&＃xff09;&＃xff1b;在 java 中&＃xff0c;简单的讲就是开启另一个线程完成程序计算&＃xff0c;使得调用者继续执行&＃xff0c;不需要等等计 算的结果&＃xff0c;但是调用者任然需要获取线程的计算结果&＃xff08;不需要同步阻塞等待&＃xff09;

Future 也是一个异步计算结果返回接口&＃xff0c;目的获取返回值结果。但是 future 在获取返回值结 构的时候&＃xff0c;方法必须同步阻塞等待返回值结果。

         Get : 获取结果&＃xff08;等待&＃xff0c;阻塞&＃xff09;

         Get(timeout) : 获取结果&＃xff0c;指定等待时间

         Cancel : 取消当前任务

          isDone : 判断任务是否已经完成 &＃xff08;轮询&＃xff09; futrure 对于结果获取不是很方便&＃xff0c;只能通过同步阻塞的方式获取结果&＃xff0c;或者是轮询的方式 获取到结果&＃xff1b;阻塞的方式获取返回值结果与异步的思想想违背&＃xff0c;轮询方式又很占用 cpu 资源&＃xff0c; 也不能及时得到我们结果。

        CompletableFuture 可以帮助我们简化异步编程复杂性&＃xff0c;提供了函数式编程的能力&＃xff0c;可以通 过回调函数的方式处理计算结果。

public class CompletableFuture implements Future, CompletionStage CompletableFuture

具有Future的特性&＃xff0c;还实现了CompletionStage接口&＃xff0c;具备CompletionStage

接口的特性&＃xff1a; 串行执行&＃xff0c;并行执行&＃xff0c;聚合&＃xff08;AND 聚合&＃xff0c;OR 聚合&＃xff09;

1&＃xff09;串行关系执行

串行关系执行&＃xff1a; then – 然后&＃xff0c;也就是表示下一步&＃xff0c;所以通常是一个串行的关系体现&＃xff0c;then 后面的单词&＃xff08;比如 run/apply/accept&＃xff09;就是函数是接口中抽象方法名称&＃xff1b;

串行关系执行&＃xff1a;利用上一步的执行结果&＃xff0c;去进行下一步任务执行&＃xff0c;任务执行具有先后顺序&＃xff0c;因此把这种操作叫做串行关系。

public CompletionStage thenRun(Runnable action);
public CompletionStage thenRunAsync(Runnable action);
public CompletionStage thenRunAsync(Runnable action,Executor executor);

public CompletionStage thenApply(Function fn);
public CompletionStage thenApplyAsync(Function fn);
public CompletionStage thenApplyAsync(Function fn,Executor executor)

thenApply此方法具有返回值&＃xff0c;上一步直接的结果当成传参的传递给thenApply

public CompletionStage thenAccept(Consumer action);
public CompletionStage thenAcceptAsync(Consumer action);
public CompletionStage thenAcceptAsync(Consumer action, Executor executor);

public CompletionStage thenCompose(Function> fn);
public CompletionStage thenComposeAsync(Function> fn);
public CompletionStage thenComposeAsync(Function> fn, Executor executor);

2&＃xff09;聚合 AND Combine…… with …… 和 both…… and …… 都是要求两者都必须满足&＃xff0c;也就是 and 且的关系。