Future 在并发 Java 编程中解决了哪些问题？

Source: Dev.to

Future 解决的问题

阻塞问题

如果没有 Future，启动后台任务的主线程通常必须 等待（阻塞）直到结果就绪，这会导致 UI 或其他工作被卡住。

结果问题

普通的 Runnable 是 “一次性触发” 的，不能返回值。将 Future 与 Callable 配合使用可以让任务 产生 一个结果（Integer、String 等），以后再取回。

控制问题

有时任务已经不再需要。Future 提供 cancel()、isDone() 等方法，能够 停止 任务或在不阻塞的情况下检查其状态。

异步执行的好处

• 提升响应性 – 主线程在后台工作进行时仍然可以继续执行其他任务。
• 安全的数据传递 – Future 负责线程之间的握手，避免竞争条件。
• 更好的控制 – 可以根据需要查询、取消或设定超时来管理任务。

在 Java 21 中使用 Future

示例：基础 Future

import java.util.concurrent.*;

public class FutureBasics {
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        // try‑with‑resources 自动关闭执行器 (Java 21+)
        try (ExecutorService executor = Executors.newFixedThreadPool(1)) {

            System.out.println("Step 1: Submitting a long task...");

            // Future 表示稍后会到达的结果
            Future futureResult = executor.submit(() -> {
                Thread.sleep(2000); // 模拟繁重计算
                return 42;
            });

            System.out.println("Step 2: Doing other work in the main thread...");

            // Step 3: 获取结果（仅在未完成时阻塞）
            Integer result = futureResult.get();

            System.out.println("Step 4: The result is: " + result);
        }
    }
}

示例：用于链式调用的 CompletableFuture

import java.util.concurrent.CompletableFuture;

public class ModernAsyncExample {
    public static void main(String[] args) {
        System.out.println("Searching for a product...");

        CompletableFuture.supplyAsync(() -> {
            simulateDelay(1000);
            return "Gaming Laptop";
        })
        .thenApply(product -> "Found: " + product + " - $1200")
        .thenAccept(finalOutput -> System.out.println("Final Result: " + finalOutput))
        .join(); // 在这个简单演示中等待完成

        System.out.println("App execution finished.");
    }

    private static void simulateDelay(int ms) {
        try { Thread.sleep(ms); } catch (InterruptedException ignored) {}
    }
}

最佳实践

• 始终使用超时：future.get(5, TimeUnit.SECONDS) 可防止无限阻塞。
• 处理异常：后台抛出的异常会被包装成 ExecutionException，请捕获并适当处理。
• 对依赖任务优先使用 CompletableFuture：使用 thenApply、thenCompose 等，而不是嵌套 Future 对象。
• 延迟阻塞调用：仅在真正需要结果时才调用 .get()，尽可能让主线程保持空闲。

结论

Future 接口是现代 Java 并发的基石。它用异步流水线取代了 “停‑等” 逻辑，使应用更快、更可靠且更易维护。掌握 Future 以及其更强大的兄弟 CompletableFuture 对于所有从事并发编程的 Java 开发者来说都是必备技能。