现实中有这样的用法，创建一批在线程池中运行的 CompletableFuture 实例，然后等待它们全部执行完再继续后面的操作。比如说 AWS 的 Lambda, 单单提交任务到线程池，不等待所有任务全部完成便退出主线程的话，AWS 便认为 Lambda 执行完毕，无视线程池中正在执行的任务而强行结束该 Lambda 实例。
以往我们通常的作法如下
|
1 2 3 4 5 6 7 8 9 10 |
ExecutorService threadPool = Executors.newFixedThreadPool(10); List<CompletableFuture<Void>> futures = IntStream.rangeClosed(1, 10000) .mapToObj(n -> CompletableFuture.runAsync(() -> { System.out.println("done " + n); }, threadPool)).collect(toList()); futures.forEach(CompletableFuture::join); System.out.println("all done"); |
如果所有的任务均无异常，上面的代码能得到预想的结果，只要上面打印出 all done 的话真的就是表明所有的任务都完成了。但是在循环 join futures 中的每一个 CompletableFuture 时，只要碰到任意一个任务有异常时，便立即抛出给外部线程，不在乎是否还有其他任务正在执行。此时，如果外部未予捕获，当然 阅读全文 >>