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); Callabletask = () -> { Thread.sleep(1000); return "done"; }; Future 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。
立即学习“Java免费学习笔记(深入)”;
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 当作普通对象反复调用 get(),又没设超时,很容易让整个调用链卡死。










