课时

讲解如何使用 CompletableFuture 启动与组合异步计算：如何通过 supplyAsync 和 runAsync 启动任务， thenApply、 thenAccept、 thenRun 这些处理器有何区别，以及何时选择它们的异步版本 thenApplyAsync/ thenAcceptAsync/ thenRunAsync。我们还会讨论执行线程（ ForkJoinPool 或你的 Executor）、结果类型（ CompletableFuture<T>、 CompletableFuture<Void>）以及常见错误：阻塞的 get()/ join()、缺少 exceptionally/ handle/ whenComplete 的异常处理，以及试图在 thenRun 内使用结果等问题。

如何使用 CompletableFuture 并行执行任务并合并结果：通过 thenCombine/ thenCombineAsync 合并两个结果，通过 allOf 等待一组任务，通过 anyOf 响应最快的结果。我们会讲解方法签名、结合 supplyAsync 的实用示例、非阻塞处理（ thenAccept、 thenRun），以及异常细节与其处理方式（ exceptionally、 handle、 whenComplete）。最后——一张精炼的对比表。

如何在 CompletableFuture 链中安全地捕获并处理异常：解析 exceptionally（出错时返回备用值）、 handle（成功/失败的通用处理器）和 whenComplete（只做副作用，不改结果）的角色。讨论为何直接调用 get()/ join() 会把根因包装为 ExecutionException/ CompletionException，如何组合各阶段（ thenApply、 thenAccept），以及要避免的常见错误。

如何用 thenCompose 在 CompletableFuture 中正确“拼接”异步步骤，以及何时只用 thenApply 就足够；为何以及如何通过 ExecutorService 接入自有线程池（而不是 ForkJoinPool.commonPool()）；如何用 orTimeout 和 completeOnTimeout 保护链路不至于“永远等待”。最后 — 实战示例：自定义 Executor、 thenCompose 与超时处理，以及常见错误与其解决方案。