CompletableFuture 详解

实际项目中，一个接口可能需要同时获取多种不同的数据，然后再汇总返回，这种场景还是挺常见的。举个例子：用户请求获取订单信息，可能需要同时获取用户信息、商品详情、物流信息、商品推荐等数据。 如果是串行（按顺序依次执行每个任务）执行的话，接口的响应速度会非常慢。考虑到这些任务之间有大部分都是 无前后顺序关联 的，可以 并行执行 ，就比如说调用获取商品详情的时候，可以同时调用获取物流信息。通过并行执行多个任务的方式，接口的响应速度会得到大幅优化。 对于存在前后调用顺序关系的任务，可以进行任务编排。 1. 获取用户信息之后，才能调用商品详情和物流信息接口。 2. 成功获取商品详情和物流信息之后，才能调用商品推荐接口。 可能会用到多线程异步任务编排的场景（这里只是举例，数据不一定是一次返回，可能会对接口进行拆分）： 1. 首页：例如技术社区的首页可能需要同时获取文章推荐列表、广告栏、文章排行榜、热门话题等信息。 2. 详情页：例如技术社区的文章详情页可能需要同时获取作者信息、文章详情、文章评论等信息。 3. 统计模块：例如技术社区的后台统计模块可能需要同时获取粉丝数汇总、文章数据（阅读量、评论量、收藏量）汇总等信息。 对于 Java 程序来说，Java 8 才被引入的 可以帮助我们来做多个任务的编排，功能非常强大。 这篇文章是 的简单入门，带大家看看 常用的 API。 Future 介绍 类是异步思想的典型运用，主要用在一些需要执行耗时任务的场景，避免程序一直原地等待耗时任务执行完成，执行效率太低。具体来说是这样的：当我们执行某一耗时的任务时，可以将这个耗时任务交给一个子线程去异步执行，同时我们可以干点其他事情，不用傻傻等待耗时任务执行完成。等我们的事情干完后，我们再通过 类获取到耗时任务的执行结果。这样一来，程序的执行效率就明显提高了。 这其实就是多线程中经典的 Future 模式 ，你可以将其看作是一种设计模式，核心思想是异步调用，主要用在多线程领域，并非 Java 语言独有。 在 Java 中， 类只是一个泛型接口，位于 包下，其中定义了 5 个方法，主要包括下面这 4 个功能： 取消任务； 判断任务是否被取消; 判断任务是否已经执行完成; 获取任务执行结果。 简单理解就是：我有一个任务，提交给了 来处理。任务执行期间我自己可以去做任何想做的事情。并且，在这期间我还可以取消任务以及获取任务的执行状态。一段时间之后，我就可以 那里直接取出任务执行结果。 CompletableFuture 介绍 在实际使用过程中存在一些局限性，比如不支持异步任务的编排组合、获取计算结果的 方法为阻塞调用。 Java 8 才被引入 类可以解决 的这些缺陷。 除了提供了更为好用和强大的 特性之外，还提供了函数式编程、异步任务编排组合（可以将多个异步任务串联起来，组成一个完整的链式调用）等能力。 下面我们来简单看看 类的定义。 可以看到， 同时实现了 和 接口。 除了提供了更为好用和强大的 特性之外，还提供了函数式编程的能力。 接口有 5 个方法： ：尝试取消执行任务。 ：判断任务是否被取消。 ：判断任务是否已经被执行完成。 ：等待任务执行完成并获取运算结果。 ：多了一个超时时间。 接口描述了一个异步计算的阶段。很多计算可以分成多个阶段或步骤，此时可以通过它将所有步骤组合起来，形成异步计算的流水线。 接口中的方法比较多， 的函数式能力就是这个接口赋予的。从这个接口的方法参数你就可以发现其大量使用了 Java8 引入的函数式编程。 由于方法众多，所以这里不能一一讲解，下文中我会介绍大部分常见方法的使用。 CompletableFuture 常见操作 创建 CompletableFuture 常见的创建 对象的方法如下： 1. 通过 new 关键字。 2. 基于 自带的静态工厂方法： 、 。 new 关键字 通过 new 关键字创建 对象这种使用方式可以看作是将 当做 来使用。 我在我的开源项目 guide rpc framework 中就是这种方式创建的 对象。 下面咱们来看一个简单的案例。 我们通过创建了一个结果值类型为 的 ，你可以把 看作是异步运算结果的载体。 假设在未来的某个时刻，我们得到了最终的结果。这时，我们可以调用 方法为其传入结果，这表示 已经被完成了。 你可以通过 方法来检查是否已经完成。 获取异步计算的结果也非常简单，直接调用 方法即可。调用 方法的线程会阻塞直到 完成运算。 如果你已经知道计算的结果的话，可以使用静态方法 来创建 。 方法底层调用的是带参数的 new 方法，只不过，这个方法不对外暴露。 静态工厂方法 这两个方法可以帮助我们封装计算逻辑。 方法接受的参数是 ，这是一个函数式接口，不允许返回值。当你需要异步操作且不关心返回结果的时候可以使用 方法。 方法接受的参数是 ，这也是一个函数式接口， 是返回结果值的类型。 当你需要异步操作且关心返回结果的时候，可以使用 方法。 处理异步结算的结果 当我们获取到异步计算的结果之后，还可以对其进行进一步的处理，比较常用的方法有下面几个： 方法接受一个 实例，用它来处理结果。 方法使用示例如下： 你还可以进行 流式调用 ： 如果你不需要从回调函数中获取返回结果，可以使用 或者 。这两个方法的区别在于 不能访问异步计算的结果。 方法的参数是 。 顾名思义， 属于消费型接口，它可以接收 1 个输入对象然后进行“消费”。 的方法是的参数是 。 和 使用示例如下： 的方法的参数是 。 相对于 ， 可以接收 2 个输入对象然后进行“消费”。 使用示例如下： 异常处理 你可以通过 方法来处理任务执行过程中可能出现的抛出异常的情况。 示例代码如下： 你还可以通过 方法来处理异常情况。 如果你想让 的结果就是异常的话，可以使用 方法为其赋值。 组合 CompletableFuture 你可以使用 按顺序链接两个 对象，实现异步的任务链。它的作用是将前一个任务的返回结果作为下一个任务的输入参数，从而形成一个依赖关系。 方法会使用示例如下： 在实际开发中，这个方法还是非常有用的。比如说，task1 和 task2 都是异步执行的，但 task1 必须执行完成后才能开始执行 task2（task2 依赖 task1 的执行结果）。 和 方法类似的还有 方法， 它同样可以组合两个 对象。 那 和 有什么区别呢？ 可以链接两个 对象，并将前一个任务的返回结果作为下一个任务的参数，它们之间存在着先后顺序。 会在两个任务都执行完成后，把两个任务的结果合并。两个任务是并行执行的，它们之间并没有先后依赖顺序。 除了 和 之外， 还有一些其他的组合 的方法用于实现不同的效果，满足不同的业务需求。 例如，如果我们想要实现 task1 和 task2 中的任意一个任务执行完后就执行 task3 的话，可以使用 。 简单举一个例子： 输出： 任务组合操作 会在异步任务 1 和异步任务 2 中的任意一个完成时触发执行任务 3，但是需要注意，这个触发时机是不确定的。如果任务 1 和任务 2 都还未完成，那么任务 3 就不能被执行。 并行运行多个 CompletableFuture 你可以通过 的 这个静态方法来并行运行多个 。 实际项目中，我们经常需要并行运行多个互不相关的任务，这些任务之间没有依赖关系，可以互相独立地运行。 比说我们要读取处理 6 个文件，这 6 个任务都是没有执行顺序依赖的任务，但是我们需要返回给用户的时候将这几个文件的处理的结果进行统计整理。像这种情况我们就可以使用并行运行多个 来处理。 示例代码如下： 经常和 方法拿来对比的是 方法。 方法会等到所有的 都运行完成之后再返回 调用 可以让程序等 和 都运行完了之后再继续执行。 输出： 方法不会等待所有的 都运行完成之后再返回，只要有一个执行完成即可！ 输出结果可能是： 也可能是： CompletableFuture 使用建议 使用自定义线程池 我们上面的代码示例中，为了方便，都没有选择自定义线程池。实际项目中，这是不可取的。 默认使用全局共享的 作为执行器，所有未指定执行器的异步任务都会使用该线程池。这意味着应用程序、多个库或框架（如 Spring、第三方库）若都依赖 ，默认情况下它们都会共享同一个线程池。 虽然 效率很高，但当同时提交大量任务时，可能会导致资源竞争和线程饥饿，进而影响系统性能。 为避免这些问题，建议为 提供自定义线程池，带来以下优势： 隔离性 ：为不同任务分配独立的线程池，避免全局线程池资源争夺。 资源控制 ：根据任务特性调整线程池大小和队列类型，优化性能表现。 异常处理 ：通过自定义 更好地处理线程中的异常情况。 尽量避免使用 get() 的 方法是阻塞的，尽量避免使用。如果必须要使用的话，需要添加超时时间，否则可能会导致主线程一直等待，无法执行其他任务。 上面这段代码在调用 时抛出了 异常。这样我们就可以在异常处理中进行相应的操作，比如取消任务、重试任务、记录日志等。 正确进行异常处理 使用 的时候一定要以正确的方式进行异常处理，避免异常丢失或者出现不可控问题。 下面是一些建议： 使用 方法可以在任务完成时触发回调函数，并正确地处理异常，而不是让异常被吞噬或丢失。 使用 方法可以处理异常并重新抛出，以便异常能够传播到后续阶段，而不是让异常被忽略或终止。 使用 方法可以处理正常的返回结果和异常，并返回一个新的结果，而不是让异常影响正常的业务逻辑。 使用 方法可以组合多个 ，并统一处理所有任务的异常，而不是让异常处理过于冗长或重复。 …… 合理组合多个异步任务 正确使用 、 、 、 、 等方法来组合多个异步任务，以满足实际业务的需求，提高程序执行效率。 实际使用中，我们还可以利用或者参考现成的异步任务编排框架，比如京东的 asyncTool。 后记 这篇文章只是简单介绍了 的核心概念和比较常用的一些 API。如果想要深入学习的话，还可以多找一些书籍和博客看，比如下面几篇文章就挺不错： CompletableFuture 原理与实践 外卖商家端 API 的异步化 美团技术团队：这篇文章详细介绍了 在实际项目中的运用。参考这篇文章，可以对项目中类似的场景进行优化，也算是一个小亮点了。这种性能优化方式比较简单且效果还不错！ 读 RocketMQ 源码，学习并发编程三大神器 勇哥 java 实战分享：这篇文章介绍了 RocketMQ 对 的应用。具体来说，从 RocketMQ 4.7 开始，RocketMQ 引入了 来实现异步消息处理。 另外，建议 G 友们可以看看京东的 asyncTool 这个并发框架，里面大量使用到了 。 写在最后 如果内容对你有帮助的话，欢迎顺手给 JavaGuide 点一个免费的 Star 支持一下：GitHub | Gitee。 JavaGuide 已持续维护近七年，累计 6100+ 次提交，来自 620+ 位贡献者共同完善。你的 Star、反馈和 PR，都是这个项目继续更新的动力。 如果你正在准备后端/AI 应用开发面试，也可以了解一下我的知识星球，里面包括后端和 AI 实战项目、简历优化、一对一提问和高频考点资料，已经持续维护六年。