Java Academy · 课时

失败与成功时关闭

Q: 「失败与成功时关闭」这节课中我会学到什么？

协调任务结果 你通过在浏览器中直接运行的动手代码来练习 Java Academy，全天候 AI 导师会在你学习这节课的过程中回答你的问题。

协调任务结果

失败与成功时关闭 是 CoddyKit 上的免费 Java Academy 课时。这是第 3 节课，共 4 节。你可以在下方免费阅读本课时的完整内容 — 然后在浏览器中使用内置代码编辑器和全天候 AI 导师进行实践。这是 Java Academy 学习路径的一部分，你的进度在网页和 CoddyKit 应用中同步。 Java Academy 课程共包含 4 节课。

两种常见模式

大多数并发扇出都属于两种模式：

必须全部成功：任一任务失败就放弃其余任务。使用 ShutdownOnFailure。
先成功者胜出：一旦某个任务成功，就取消其余任务。使用 ShutdownOnSuccess。

JDK 开箱即用地提供了这两种策略。

ShutdownOnFailure 的原理

ShutdownOnFailure 适用于所有任务都必须成功的场景，例如同时获取用户资料和其订单。

如果某个子任务抛出异常，scope 会取消其他子任务，从而避免浪费工作。

ShutdownOnFailure 示例

在 join() 之后调用 throwIfFailed()，它会重新抛出第一个失败（如果有），并将其包装在 ExecutionException 中。

import java.util.concurrent.StructuredTaskScope;

public class Main {
    public static void main(String[] args) throws Exception {
        try (var scope = new StructuredTaskScope.ShutdownOnFailure()) {
            var a = scope.fork(() -> fetch("profile"));
            var b = scope.fork(() -> fetch("orders"));
            scope.join();
            scope.throwIfFailed();
            System.out.println(a.get() + " + " + b.get());
        }
    }

    static String fetch(String what) {
        return what + "-ok";
    }
}

throwIfFailed 的作用

throwIfFailed() 会检查所有子任务。如果全部成功，它不会执行任何操作。如果有任何子任务失败，它就会抛出异常，并包装原始异常。

您也可以传入一个函数，将异常原因映射为自定义异常类型。

ShutdownOnSuccess 的原理

ShutdownOnSuccess 适用于冗余请求或竞速场景：查询多个镜像，并采用最先响应的那个。

一旦某个子任务成功，scope 就会取消其余子任务并保存获胜结果。

ShutdownOnSuccess 示例

您可以通过 result() 获取获胜的值。如果没有任何子任务成功，它就会抛出异常。

import java.util.concurrent.StructuredTaskScope;

public class Main {
    public static void main(String[] args) throws Exception {
        try (var scope = new StructuredTaskScope.ShutdownOnSuccess<String>()) {
            scope.fork(() -> queryMirror("eu"));
            scope.fork(() -> queryMirror("us"));
            scope.join();
            System.out.println("Fastest answer: " + scope.result());
        }
    }

    static String queryMirror(String region) {
        return region + "-data";
    }
}

result 与 get 的区别

请注意两者的区别：

ShutdownOnFailure：分别使用每个子任务自己的 get() 读取结果
ShutdownOnSuccess：使用 scope 的 result() 读取唯一的获胜结果

取消是协作式的

scope 关闭时，会中断剩余的子任务线程。行为良好的任务会检查中断状态并及时停止。

标准库中的阻塞调用通常会自动响应中断。

带超时的 join

两种策略都支持截止时间。调用 joinUntil(Instant) 只会等待到指定时间点，随后抛出 TimeoutException 并关闭 scope。

选择策略

请问自己一个问题：我需要所有结果，还是只需要第一个？

需要所有结果，并在出现错误时快速失败：ShutdownOnFailure
任意一个结果即可，由最快者胜出：ShutdownOnSuccess

其他情况请继承 StructuredTaskScope。

自定义策略

您可以继承 StructuredTaskScope，并重写 handleComplete(Subtask) 来实现定制规则，例如收集前 N 个成功结果，或在失败次数达到配额后关闭。

快速检查

将场景与策略匹配起来。

回顾

您已经学习了两种内置的关闭策略：

对于必须全部成功的场景，使用 ShutdownOnFailure + throwIfFailed + 每个子任务的 get
对于先成功者胜出的场景，使用 ShutdownOnSuccess + result
关闭操作会以协作方式中断剩余的子任务
joinUntil 增加截止时间；继承接口可以增加自定义规则

下一步：详细学习错误处理和取消。

常见问题解答

「失败与成功时关闭」课时是免费的吗？

是的 — 「失败与成功时关闭」的完整文本可在网页上免费阅读。要进行交互式练习（内置代码编辑器和全天候 AI 导师）并解锁 Java Academy 课程的其余内容，请升级到 CoddyKit PRO。 Java Academy 课程共包含 4 节课。

「失败与成功时关闭」这节课中我会学到什么？

协调任务结果你通过在浏览器中直接运行的动手代码来练习 Java Academy，全天候 AI 导师会在你学习这节课的过程中回答你的问题。

学习 Java Academy 需要有经验吗？

无需任何先前经验。CoddyKit 上的 Java Academy 课程适合初学者到高级学习者，你可以从这里开始或从头开始，按照自己的节奏学习。这是第 3 节课，共 4 节。

「失败与成功时关闭」课时需要多长时间？

大多数 CoddyKit 课程大约需要 5–10 分钟。每节课都很精短且互动，所以你能稳步进步，并在网页和应用中从离开的地方继续。

我能在这节 Java Academy 课中编写并运行代码吗？

能。每节 Java Academy 课都包含内置代码编辑器，你可以在浏览器中直接编写并运行真实代码，并获得即时 AI 反馈 — 无需本地设置。

此课程中的所有课时

← 返回 Java Academy