Java8已经发布7年了，不会还有人没用过CompletableFuture吧

　　前言
　　CompletableFuture实现了CompletionStage接口和Future接口，前者是对后者的一个扩展，增加了异步回调、流式处理、多个Future组合处理的能力，使Java在处理多任务的协同工作时更加顺畅便利。  Future有哪些缺陷？
　　多线程的场景下，我们要监听每个线程异步执行的结果，如果用Future去实现，代码如下：  /**  * Future异步示例  *  * @author liudong  * @date 2021/12/9 15:37  */ public class FutureDemo {     public static void main(String[] args) throws Exception {         // 1. 创建线程池         ExecutorService executorService = Executors.newCachedThreadPool();         // 2. 提交任务         List> tasks = new ArrayList<>();         ArrayList taskIds = Lists.newArrayList(1, 2, 3);         taskIds.forEach(taskId -> {             Callable task = () -> {                 Thread.sleep(1000);                 return ＂任务＂ + taskId + ＂执行完成！＂;             };             tasks.add(task);         });         List> futures = executorService.invokeAll(tasks);         // 3. 获取任务执行结果         for (Future future : futures) {             String result = future.get();             System.out.println(result);         }         executorService.shutdown();     } }
　　执行结果  任务1执行完毕！ 任务2执行完毕！ 任务3执行完毕！
　　大家有没有思考过这样使用有没有什么问题？笔者认为有如下几个 缺陷 :  (1) 不能回调会阻塞  (2) 批量任务处理彼此依赖会阻塞  (3) 不能多个任务级联执行，将结果依次往下传递  (4) 得不到最先完成的任务  CompletableFuture能解决吗？
　　针对如上几个问题，看看CompletableFuture是怎么解决的。
　　使用CompletableFuture提供的supplyAsync和whenCompleteAsync两个方法优化以上代码，如下：  /**  * CompletableFuture异步示例  *  * @author liudong  * @date 2021/12/9 15:37  */ public class CompletableFutureDemo {     public static void main(String[] args) throws Exception {         // 1. 创建线程池         ExecutorService executorService = Executors.newCachedThreadPool();         // 2. 提交任务         List> tasks = new ArrayList<>();         ArrayList taskIds = Lists.newArrayList(1, 2, 3);         // 3. 回调任务执行结果         List> completableFutures = new ArrayList<>();         CompletableFuture[] cfs = taskIds.stream().map((taskId) -> {             CompletableFuture completableFuture = CompletableFuture.supplyAsync(() -> {                 try {                     Thread.sleep(1000L);                 } catch (InterruptedException e) {                 }                 return ＂任务＂ + taskId + ＂执行完成！＂;             }, executorService);             // 异步返回执行结果             completableFuture.whenCompleteAsync((result, exception) -> {                 System.out.println(result);             });             // 将处理结果传递到子任务             completableFuture.thenAccept((result) -> {                 System.out.println(＂上级任务处理结果：＂ + result);             });             return completableFuture;         }).toArray(CompletableFuture[]::new);                  // 获取最先执行完的任务         CompletableFuture