java CompletionStage CompletableFuture

java.util.concurrent.CompletionStage

 

 * <li>The computation performed by a stage may be expressed as a

 * Function, Consumer, or Runnable (using methods with names including

 * <em>apply</em>, <em>accept</em>, or <em>run</em>, respectively)

 * depending on whether it requires arguments and/or produces results.

 * For example, {@code stage.thenApply(x -> square(x)).thenAccept(x ->

 * System.out.print(x)).thenRun(() -> System.out.println())}. An

 * additional form (<em>compose</em>) applies functions of stages

 * themselves, rather than their results. </li>

 

方法分为几类：

一、单stage场景下的

apply，使用上个stage的result作为入参，产出新的result

accept，消费上个stage产出的result

run，既不消费也不产出

 

二、多个stage场景下的方法，以下关键字分别跟上名几个方法类别组合

both，两个stage都完成

  1、combine方法，把两个stage的产出合并成一个产出

  2、AcceptBoth，消费两个stage的产出

  3、runAfterBoth

either，任意一个stage完成，但是下一个stage消费的不能确定是哪个stage产出的

  1、applyToEither

  2、acceptEither

  3、runAfterEither

 

以上每个方法又分为三种

1、同步的

2、异步（带async），使用默认线程池

3、异步（入参有executor），使用指定线程池

 

三、异常处理

exceptionally 前个stage有exception时，返回自定义result，如果没有exception，则输出前个stage的result

whenComplete，前一个stage的exception和result作为入参，返回一个新的stage，这个stage跟前一个stage拥有一样的result和exception

handle，前一个stage的exception和result作为入参，返回一个新的stage，这个stage的result是函数生成的result

 

 

 

 java.util.concurrent.CompletableFuture

anyOf 任意一个stage完成，创建的新stage就完成

allOf  所有stage完成，创建的新stage才完成

如果anyOf、allOf列表里的stage是异步执行的，它们会在默认的线程池里运行，而程序会继续运行，有可能在所有stage都完成之前程序就退出了，导致stage并没有全部完成，需要所有stage都完成的话，需要使用join或者get等待