applyToEither 怎么使用

applytoeither 用于在两个 completablefuture 中，谁先完成就执行谁的转换逻辑并返回结果。调用时传入另一个 completablefuture 和一个 function，该函数仅对获胜方的结果生效，最终返回一个包含转换后结果的 completablefuture。

如何结合超时处理实现竞速

通过 orTimeout 或 completeOnTimeout 配合 applyToEither 可以实现竞速逻辑。将主任务与超时任务（如抛出异常或返回默认值）进行竞争，确保程序不会无限期等待。

JavaScript 开发专家

掌握包含 ES6+、异步模式和 Node.js API 的现代 JavaScript。处理 Promise、事件循环和浏览器/Node 兼容性。在 JavaSc

下载

import java.util.concurrent.CompletableFuture;
import java.util.concurrent.TimeUnit;

public class RaceExample {
    public static void main(String[] args) throws Exception {
        CompletableFuture<string> slowTask = CompletableFuture.supplyAsync(() -> {
            try { TimeUnit.SECONDS.sleep(3); } catch (InterruptedException e) {}
            return "Slow Result";
        });

        CompletableFuture<string> fastFallback = CompletableFuture.completedFuture("Fast Fallback");

        // 慢任务如果超过1秒未完成，fastFallback 会立即触发
        CompletableFuture<string> result = slowTask
                .orTimeout(1, TimeUnit.SECONDS)
                .applyToEither(fastFallback, r -> r);

        System.out.println(result.get()); // 输出: Fast Fallback
    }
}</string></string></string>

基于输入条件判断的具体问题

当两个任务都成功完成时，applyToEither 只执行第一个完成的任务对应的 Function，另一个任务的结果会被丢弃。如果第一个完成的任务抛出异常，整个链式调用将变为异常状态。

import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;

public class EitherLogic {
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        CompletableFuture<integer> taskA = CompletableFuture.supplyAsync(() -> {
            try { Thread.sleep(500); } catch (InterruptedException e) {}
            return 10;
        });

        CompletableFuture<integer> taskB = CompletableFuture.supplyAsync(() -> {
            try { Thread.sleep(100); } catch (InterruptedException e) {}
            return 20;
        });

        // taskB 先完成，applyToEither 使用 taskB 的结果 20
        // 即使 taskA 稍后完成，其结果也不会被应用
        CompletableFuture<integer> winner = taskA.applyToEither(taskB, val -> val * 2);

        System.out.println(winner.get()); // 输出: 40
    }
}</integer></integer></integer>

Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南