Java Future.state 怎样区分未完成、成功和失败

Java 并发代码里，isDone() 只能说明任务结束了，不能直接说明它是成功、失败还是取消。更稳妥的做法是先调用 Future.state()，再按 Future.State 分支处理：RUNNING 继续等待或轮询，SUCCESS 才读取 resultNow()，FAILED 才读取 exceptionNow()，CANCELLED 则进入取消清理。

官方文档：https://docs.oracle.com/en/java/javase/25/docs/api/java.base/java/util/concurrent/Future.html

一、先用 state 判断任务处于哪一类状态

Future.State 把任务结果分成四类。RUNNING 表示尚未完成；SUCCESS 表示正常结束；FAILED 表示计算抛出了异常；CANCELLED 表示任务在正常完成前被取消。这个划分比同时组合 isDone()、isCancelled() 和一次试探性 get() 更直接。

可以把状态转换成业务层的明确动作：

二、按状态安全读取 resultNow 或 exceptionNow

下面的分支适合放在轮询器、任务收尾回调或批处理汇总处。关键点是先读状态，再读对应值；如果状态还是 RUNNING，就返回“尚未完成”，而不是为了拿到结果强行阻塞。

import java.util.concurrent.Future;
import java.util.concurrent.Future.State;

static  void consume(Future future) {
    // 先判断状态，避免在任务未结束时读取非阻塞结果。
    State state = future.state();
    switch (state) {
        case SUCCESS -> {
            // SUCCESS 才允许读取 resultNow；这里不会再次等待。
            T value = future.resultNow();
            System.out.println("完成：" + value);
        }
        case FAILED -> {
            // FAILED 才读取 exceptionNow，并保留原始异常用于记录或重试。
            Throwable error = future.exceptionNow();
            System.err.println("失败：" + error.getMessage());
        }
        case CANCELLED -> {
            // 取消分支负责释放与任务绑定的业务资源。
            System.out.println("已取消，跳过结果处理");
        }
        case RUNNING -> {
            // 未完成时退出本次轮询，由上层调度下一次检查。
            System.out.println("仍在运行");
        }
    }
}

不要把 resultNow() 当成“更快的 get”。它的价值是让已经确认完成的任务直接取值；如果任务尚未完成、以异常结束或已取消，调用就会因为前置条件不满足而失败。exceptionNow() 也一样，只适合明确处于 FAILED 的任务。

三、把状态判定放进轮询和收尾逻辑

批处理任务通常需要重复检查。轮询函数可以只返回三种业务信号：继续等待、拿到结果、结束但需要处理异常。这样调用方不会把“任务完成”误解成“任务成功”。

static  boolean pollOnce(Future future) {
    // 返回 true 表示本轮已经完成，false 表示稍后再检查。
    switch (future.state()) {
        case RUNNING -> { return false; }
        case SUCCESS -> {
            // 只在成功状态取值，避免把取消误当成空结果。
            handleValue(future.resultNow());
            return true;
        }
        case FAILED -> {
            // 失败状态读取异常，交给统一重试或降级策略。
            handleFailure(future.exceptionNow());
            return true;
        }
        case CANCELLED -> {
            // 取消是独立终态，执行清理但不触发普通失败告警。
            handleCancellation();
            return true;
        }
    }
    return true;
}

如果业务必须等待结果，仍然可以使用 get() 或带超时的 get(timeout, unit)。state() 适合“我现在要不要读取”的判断；它不是把阻塞等待自动变成异步。

四、检查版本与实现边界

Future.state()、resultNow() 和 exceptionNow() 自 Java 19 起提供，使用旧 JDK 编译时要先确认目标运行环境。Java SE 25 文档还说明，接口默认的 state() 实现可能借助 isDone()、isCancelled() 和 get() 判断状态，所以自定义 Future 如果需要严格的非阻塞语义，应查看具体实现是否覆盖了这些方法。

排查时可以按这个顺序核对：先确认任务是否已提交；再确认轮询是否保留同一个 Future；接着记录 state() 的值；最后才调用对应的非阻塞读取方法。这样能把“还没结束”“异常结束”和“主动取消”分开处理。

相关问题

Future.isDone() 为 true 就能调用 resultNow() 吗？

不能。isDone() 也会在失败或取消时返回 true，必须先确认 state() == SUCCESS。

FAILED 和 CANCELLED 为什么要分开记录？

FAILED 表示计算本身出现异常，通常需要重试或告警；CANCELLED 通常来自超时、用户撤销或上游关闭，处理重点是清理和幂等收尾。