在Java中Future与Callable怎么配合_Java异步结果处理说明_技术教程

Callable 是能返回值并抛出受检异常的异步任务接口；不能用 new Thread(new Runnable()) 替代，因其无法获取结果、等待完成或捕获受检异常，必须配合 Future 和
ExecutorService.submit() 使用。

Callable 是什么，为什么不能直接 new Thread(new Runnable()) 替代

Callable 和 Runnable 都表示可执行任务，但关键区别在于：Callable 的 call() 方法能返回值、抛出受检异常；Runnable 的 run() 不能。这意味着如果你需要异步计算一个 Integer、List 或其他具体类型结果，Runnable 就无能为力。

直接用 new Thread(new Runnable()) 启动线程，你拿不到执行结果——没有返回值、无法等待完成、也没法捕获 call() 中抛出的 SQLException 这类异常。

所以必须配合 Future：它是个“占位符”，代表一个**尚未完成但未来会有的结果**。

submit(Callable) 返回 Future，不是 start() 或 run()

别把 Future 当成线程控制接口。它不启动任务，也不提供 start()、run() 方法。它的作用纯粹是：获取结果、判断状态、取消任务。

真正提交并触发执行的是 ExecutorService.submit()：

ExecutorService executor = Executors.newFixedThreadPool(2);
Future future = executor.submit(() -> {
    Thread.sleep(1000);
    return "done";
});

上面这行 submit() 才是关键动作。它内部做了三件事：包装 Callable、调度到线程池、返回一个可查询的 Future 实例。

future.get() 会阻塞，直到任务完成（或超时/被中断）
future.isDone() 查是否执行完毕（不管成功失败）
future.cancel(true) 尝试中断正在运行的线程（仅当任务响应中断）

get() 阻塞风险与 timeout 必须显式设

Future.get() 默认无限期等待，生产环境几乎从不这么用。一旦后端服务卡死、网络超时、或任务本身死循环，调用线程就会永久挂起。

必须用带超时的重载：

try {
    String result = future.get(3, TimeUnit.SECONDS); // 3秒超时
} catch (TimeoutException e) {
    // 任务没在3秒内完成，future.cancel(true) 可选
} catch (ExecutionException e) {
    // call() 抛出的异常被包在这里，e.getCause() 才是原始异常
} catch (InterruptedException e) {
    Thread.currentThread().interrupt();
}

注意两点：

ExecutionException 是包装器，真实异常在 e.getCause() 里，比如你 call() 中写了 throw new IOException("db fail")，这里要 e.getCause() instanceof IOException 才能捕获
cancel(true) 并不保证线程立刻停止——它只是调用 Thread.interrupt()，任务代码得自己检查 Thread.currentThread().isInterrupted() 并退出

CompletableFuture 比 Future + Callable 更实用

原生 Future 功能太弱：不能链式处理、无法组合多个异步任务、异常处理笨重、不支持非阻塞回调。

现实中，只要 JDK ≥ 8，优先用 CompletableFuture：

CompletableFuture.supplyAsync(() -> {
    return fetchDataFromDB(); // 返回 String
}).thenApply(s -> s.toUpperCase())
 .exceptionally(t -> "fallback")
 .join(); // 阻塞等结果，或用 thenAccept 异步消费

它底层仍基于 Executor 和 Callable，但封装了所有样板逻辑。你不再需要手动管理 Future 状态、写一堆 try/catch 套娃，也不用担心忘记设超时。

真要兼容老代码或定制调度策略时，才退回 ExecutorService.submit(Callable) + Future。其余情况，CompletableFuture 是更安全、更灵活的选择。