Java CompletableFuture resultNow 怎样读取已完成结果

如果一组 CompletableFuture 已经完成，并且调用方只想拿到“确认成功”的结果，Java 19 提供的 resultNow() 很合适：它直接返回计算结果，不等待，也不接收备用值。关键前提是先知道任务已经以成功状态完成；它不是超时控制器，也不是异常降级器。

官方 API 参考：https://docs.oracle.com/en/java/javase/25/docs/api/java.base/java/util/concurrent/CompletableFuture.html

先理解 resultNow 的使用前提

CompletableFuture 同时实现了 CompletionStage 和 Future。从 Java 19 开始，Future 增加了 state()、resultNow() 和 exceptionNow() 这组非阻塞读取工具。resultNow() 只回答一个问题：当前任务已经成功算出结果时，这个结果是什么。

因此，下面两个动作要分开：等待任务完成属于编排层，读取已知成功结果属于汇总层。如果还不能证明任务成功完成，就不能把 resultNow() 当作“试着读一下”的 API。官方契约明确规定，任务没有完成，或没有成功结果时，调用可能得到 IllegalStateException。

用 state 过滤成功任务后提取结果

批量任务是 resultNow() 最清楚的应用场景：先把所有任务交给上游编排，等批次完成后按照状态分类，只有成功项进入结果列表。这样做的好处是读取动作天然无阻塞，失败和取消也不会被悄悄当成空值。

import java.util.List;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.Future;

class ResultCollector {
    static List collectSuccessful(List> tasks) {
        return tasks.stream()
                // 只把已经成功完成的任务交给 resultNow，避免误读未完成或失败状态。
                .filter(task -> task.state() == Future.State.SUCCESS)
                // 这里不会等待；状态前提已经由上一行筛选完成。
                .map(Future::resultNow)
                .toList();
    }
}

这里的 state() 不是“是否完成”的简单布尔值，而是把结果分成未完成、成功、失败和取消等状态。只筛选 SUCCESS，可以明确表达“我只要已经产生正常结果的任务”。如果还要统计失败原因，就应该把失败任务交给 exceptionNow()，而不是对它们调用 resultNow()。

区分未完成、异常和取消三种边界

三个边界看起来都像“没有结果”，处理方式却不同。

import java.util.concurrent.CancellationException;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.Future;

class FutureStateReporter {
    static String describe(CompletableFuture task) {
        return switch (task.state()) {
            case SUCCESS -> {
                // 成功状态才读取值，resultNow 不会为这个分支额外等待。
                yield "成功：" + task.resultNow();
            }
            case FAILED -> {
                // 失败状态读取根因，不用 resultNow 把失败包装成普通结果。
                yield "失败：" + task.exceptionNow().getClass().getSimpleName();
            }
            case CANCELLED -> {
                // 取消是独立状态，保留它与异常失败的区别。
                yield "已取消：" + CancellationException.class.getSimpleName();
            }
            case RUNNING -> "尚未完成";
        };
    }
}

示例中的 switch 只负责展示状态分流。生产代码如果需要等待，应在更上游使用 allOf、超时策略或任务编排器，等批次达到约定状态后再进入收集函数。不要为了让 resultNow “不报错”而捕获 IllegalStateException 后返回空字符串，那会把编排错误隐藏到业务数据里。

对比 resultNow、getNow 与 join

三个方法的名字相似，但调用意图不同：

• resultNow()：调用者已经知道任务成功完成，只做立即读取；未完成或没有成功结果时失败。
• getNow(defaultValue)：任务未完成时返回备用值；已失败或已取消时仍可能抛出对应异常。
• join()：必要时等待任务完成，正常返回结果，失败时通常以 CompletionException 传播。

import java.util.concurrent.CompletableFuture;

class ReadChoice {
    static String readAfterSuccess(CompletableFuture task) {
        // 调用方已经完成状态分流，所以这里用 resultNow 表达“只读成功结果”。
        return task.resultNow();
    }

    static String readWithFallback(CompletableFuture task) {
        // 任务未完成时返回备用文本；这不是对异常完成的统一降级。
        return task.getNow("暂不可用");
    }

    static String readAndWait(CompletableFuture task) {
        // 允许当前线程等待时使用 join；失败会以 CompletionException 传播。
        return task.join();
    }
}

选择方法时，先问“这里能不能等”和“未完成时有没有业务备用值”。如果答案是不能等且已经完成成功，选 resultNow；如果需要一个明确的未完成占位，选 getNow；如果这是同步边界、等待是允许的，才使用 join。这一层判断比记住方法名更重要。

把读取策略放进结果汇总层

我更倾向于把 resultNow 放在一个很窄的汇总函数里：上游负责启动任务、等待批次、定义超时和处理失败；汇总函数只接受状态已经符合约定的 Future。这样代码的责任边界清楚，也方便在测试中分别覆盖成功、未完成、异常和取消四个场景。

如果任务列表来自多个来源，先记录每项的状态，再决定是否输出部分成功结果。部分成功不是 resultNow 自动提供的策略，而是业务层对失败项、取消项和重试项做出的选择。这个区分能避免“为了拿到一个列表”而吞掉异常。

常见问题

resultNow 会不会等待 CompletableFuture 完成？

不会。它只读取已经计算出的结果；等待应由 join、get、超时编排或其他上游逻辑负责。

Future 已经 isDone()，就能直接调用 resultNow 吗？

不一定。isDone() 只说明任务以某种方式结束，失败和取消也算结束。要读取业务结果，最好确认 state() == Future.State.SUCCESS。

getNow 和 resultNow 最大的区别是什么？

getNow 在未完成时可以返回调用者提供的备用值，resultNow 则要求调用者已经确认成功状态。前者表达“没有结果时怎么办”，后者表达“结果已确定，立即拿出来”。

异常完成时应该用 resultNow 读取异常吗？

不应该。先通过 state() 分流，再用 exceptionNow() 读取失败原因；是否重试、降级或记录告警属于业务策略。