Java使用Callable和Future获取线程结果详解

“纵有疾风来，人生不言弃”，这句话送给正在学习文章的朋友们，也希望在阅读本文《Java如何用Callable和Future获取线程结果》后，能够真的帮助到大家。我也会在后续的文章中，陆续更新文章相关的技术文章，有好的建议欢迎大家在评论留言，非常感谢！

Callable 和 Runnable 的核心区别在于：Callable 的 call() 方法有返回值且可抛异常，Runnable 的 run() 方法无返回值且不能抛受检异常；前者适用于需获取结果的场景，后者适用于无需返回的场景。

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学习网公众号，带你了解更多关于的知识点！