Java如何用Callable和Future获取线程结果

Java中，Callable与Runnable的核心差异在于前者支持返回结果和抛出异常，后者则不能，因此当需要获取线程执行后的计算结果（如远程调用、数据库查询）时，必须选用Callable，并通过ExecutorService提交以获得Future对象；Future作为异步结果的“占位符”，提供了isDone()、cancel()、带超时的get()等灵活控制能力，但需警惕其阻塞特性——直接调用无超时的get()极易导致线程卡死，推荐结合超时机制或升级至CompletableFuture实现真正的非阻塞异步编排；同时务必注意异常被包装为ExecutionException，原始业务异常需通过e.getCause()提取，否则将无法正确捕获和处理。

Callable 和 Runnable 的核心区别在哪

Runnable 的 run() 方法不能返回值、也不能抛出受检异常；Callable 的 call() 方法必须返回一个泛型结果，且可以抛出异常。这意味着如果你需要线程执行后拿到计算结果（比如查询数据库返回 List），就必须用 Callable，而不是 Runnable。

• Runnable 适合“只做事不回话”的场景，例如日志写入、缓存刷新
• Callable 适合“做完要交作业”的场景，例如远程接口调用、复杂计算、文件解析
• 直接 new Thread(new Callable(...)) 是**行不通的**——Thread 构造器只接受 Runnable，必须通过 ExecutorService 提交

如何用 ExecutorService 提交 Callable 并获取 Future

Future 是对异步计算结果的“占位符”，它不保存结果本身，而是提供检查、等待、取值的控制能力。关键点是：Future 不会自动触发执行，必须由线程池调度。

ExecutorService executor = Executors.newFixedThreadPool(2);
Callable<String> task = () -> {
    Thread.sleep(1000);
    return "done";
};
Future<String> future = executor.submit(task); // 提交后立即返回 Future

// 后续可多次调用，但 get() 是阻塞的
try {
    String result = future.get(); // 等待完成并取值
} catch (ExecutionException e) {
    // 注意：原始异常被包装在 ExecutionException 中，e.getCause() 才是你的业务异常
} finally {
    executor.shutdown();
}

• future.isDone() 判断是否执行完毕（非阻塞）
• future.cancel(true) 尝试中断正在运行的任务（是否生效取决于任务内部是否响应中断）
• future.get(3, TimeUnit.SECONDS) 带超时的取值，超时抛出 TimeoutException

Future.get() 阻塞问题怎么破

直接调用 future.get() 会卡住当前线程，这在 Web 请求或 UI 线程中不可接受。常见解法不是“避免 Future”，而是“换一种等法”。

• 用 isDone() + 自旋轮询（仅限低频、短耗时任务，否则浪费 CPU）
• 用 get(timeout, unit) 控制最大等待时间，超时后走降级逻辑（如返回缓存值）
• 升级到 CompletableFuture：支持回调（thenApply）、组合（thenCombine）、异常处理（exceptionally），真正实现非阻塞链式异步
• 注意：多个 Future.get() 串行调用仍是同步等待，想并行取结果，得用 invokeAll() 或 CompletableFuture.allOf()

为什么有时 Future.get() 拿不到预期异常

当你在 call() 中 throw new IOException()，future.get() 却抛出 ExecutionException，而不是原始异常——这是设计使然，Future 统一将任务内抛出的任何异常包装为 ExecutionException 的 cause。

try {
    future.get();
} catch (ExecutionException e) {
    Throwable cause = e.getCause();
    if (cause instanceof IOException) {
        // 这里才能捕获你 throw 的 IOException
    }
}

• 不要直接 catch IOException，那是徒劳的
• 如果任务因线程被中断而失败，e.getCause() 可能是 CancellationException
• 如果任务还没开始就被 cancel，future.isCancelled() 为 true，此时调用 get() 也会抛 CancellationException

Future 本身只是个接口，真正容易出错的地方不在写法，而在对“异步结果何时就绪”和“异常传播路径”的误判。尤其是把 Future 当作普通对象反复调用 get()，又没设超时，很容易让整个调用链卡死。

以上就是《Java如何用Callable和Future获取线程结果》的详细内容，更多关于的资料请关注golang学习网公众号！