并发编程中的异步编程

runAsync(_Runnable runnable)_

不带返回值的异步执行方法 ，默认使用ForkjoinPoll

runAsync(_Runnable runnable,Executor executor)_

不带返回值的异步执行方法 使用自定义线程池

get()

阻塞等待执行结果 在唤醒继续执行
允许被中断

join()

阻塞等待执行结果
不允许被中断

allOf()

接收多个CompletableFuture无返回值的任务当 所有的CompletableFuture任务执行结束后 返回一个新的CompletableFuture对象

CompletableFuture<Void> voidCompletableFuture = CompletableFuture.runAsync(() -> {
            System.out.println("111");
        });
        CompletableFuture<Void> voidCompletableFuture1 = CompletableFuture.runAsync(() -> {
            System.out.println("111");
        });
        CompletableFuture.allOf(voidCompletableFuture,voidCompletableFuture1).join();

anyOf()

接收多个 CompletableFuture带返回值的任务 当任何一个 CompletableFuture任务执行完成后返回一个新的CompletableFuture对象

thenAccept（）

对 anyOf()返回的结果进行进一步的处理

 CompletableFuture<String> voidCompletableFuture = CompletableFuture.supplyAsync(() -> {
           return "1";
        });
        CompletableFuture<String> voidCompletableFuture1 = CompletableFuture.supplyAsync(() -> {
           return "2";
        });
        CompletableFuture.anyOf(voidCompletableFuture,voidCompletableFuture1).thenAccept(value-> System.out.println(value)).join();

completedFuture()

指定一个返回结果

CompletableFuture.completedFuture("1");

getNow()

如果当前任务已经执行完成 则返回执行结果 否则返回传递进去的参数

消费类型的方法

依赖单个任务完成

thenAccept()
thenAcceptAsync()

依赖两个 任务完成

thenAcceptBoth()
thenAcceptBothAsync()

   CompletableFuture<String> voidCompletableFuture = CompletableFuture.supplyAsync(() -> {
           return "1";
        });
        CompletableFuture<String> voidCompletableFuture1 = CompletableFuture.supplyAsync(() -> {
           return "2";
        });
        voidCompletableFuture.thenAcceptBothAsync(voidCompletableFuture1,(r1,r2)->{
            System.out.println("111");
        });

依赖两个任务中的任何一个完成

acceptEither（）
acceptEitherAsync()
两个任务中有一个完成就可以继续执行 方法

有返回值类型的方法

依赖单个任务完成

thenAppl()
thenApplyAsync()

依赖两个 任务完成

thenCombine()
thenCombineAsync()

依赖两个任务中的任何一个完成

applyToEither()
applyToEitherAsync()

不消费也不返回新值的方法

不依赖上一阶段返回结果 只要上一阶段完成 就执行指定的任务

依赖单个任务完成

thenRun()
thenRunAsync()

依赖两个 任务完成

runAfterBothAsync（）
runAfterBoth()

依赖两个任务中的任何一个完成

runAfterEither()
runAfterEitherAsync()

组合类型的方法

把第一个任务的执行结果作为参数传递给第二个执行
thenCombineAsync()
thenCombine()

异常处理

whenComplete()

.whenComplete((result, e) -> {
            if (e != null) {
                LogUtil.error(e,LOGGER, "Select Build Dic , {0}", e.getMessage());
            }

whenCompleteAsync()

handle

表示前置任务执行完成后 不管前置任务执行状态是正常还是异常 都执行其中的函数

handle()
handleAsync()

exceptionally

接收一个函数fn 当上一个任务出现异常时 会将该异常作为参数传递给函数fn
exceptionally()

源码

    volatile Object result;      //表示CompletableFuture的返回结果或者一个异常对象的封装对象
    volatile Completion stack;   //链式异步调用中传递的任务都会被压入 stack中