Java 线程池（第六篇）：Runnable / Callable / Future / submit / execute 全解析：异步任务的正确使用方式-开发者社区

前面几篇我们把线程池的“池”讲透了：ThreadPoolExecutor 的工作机制、拒绝策略、调优、定时任务，以及生产级封装。
但在真实项目里，最容易踩坑的并不是线程池参数，而是——你到底是怎么把任务扔进去的：

execute()和submit()有什么区别？
为什么有人说 “submit 会吞异常”？
Runnable和Callable的本质差别是什么？
Future.get()为什么会把线程卡死？
超时、取消、中断到底怎么配合使用？

本篇把这条链路一次讲透。

1. Runnable vs Callable：差别就两点

Runnable

没返回值
不能直接抛出受检异常（只能内部 try/catch）

Runnable r = () -> System.out.println("run");

Callable<V>

有返回值V
可以抛异常（会体现在 Future 上）

Callable<Integer> c = () -> 1 + 1;

句话记忆：

Runnable = “干活不回话”
Callable = “干活还给结果（或告诉你失败原因）”

2. execute vs submit：这是面试必问点

execute(Runnable)

只接收 Runnable
没有返回值
如果任务抛异常：异常会走线程的 uncaught 逻辑（通常会打印栈，但不回到调用方）

executor.execute(() -> { throw new RuntimeException("boom"); });

submit(...)

可以接收 Runnable / Callable
返回 Future
如果任务抛异常：异常不会直接抛给调用方，会被封装进 Future（你不 get 就“像没发生过”）

Future<?> f = executor.submit(() -> { throw new RuntimeException("boom"); });

关键差异：
execute：异常“向外冒”（到线程层面）
submit：异常“装进 Future”（你不 get 就看不到）

3. submit 为啥“吞异常”？——你不 get，它就不报

看这个最小复现：

ExecutorService pool = Executors.newFixedThreadPool(1); pool.submit(() -> { throw new RuntimeException("submit error"); }); // 如果你不调用 get()，很多情况下你不会在日志里看到异常栈

正确姿势：

Future<?> f = pool.submit(() -> { throw new RuntimeException("submit error"); }); try { f.get(); // 这里会抛 ExecutionException } catch (ExecutionException e) { System.out.println("真实异常 = " + e.getCause()); } catch (Exception ignored) {}

所以结论非常明确：

submit 不是真的吞异常，它是把异常“延迟到 get() 时再抛”。
你不 get，就等于“你选择不看”。

这也是为什么生产中你需要（第五篇）提到的SafeRunnable / 统一异常捕获。

tips：Java 线程池（第五篇）：生产级线程池封装方案（统一命名、异常捕获、监控与超时控制）

4. Future 到底是什么？它解决的是什么问题？

Future 的意义是：

你提交任务后，立刻返回一个“凭证”
你可以：
get()等结果（阻塞）
get(timeout)限时等待（避免卡死）
cancel(true)尝试取消 + 中断任务
isDone()轮询是否完成

核心接口：

V get() throws InterruptedException, ExecutionException; V get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException; boolean cancel(boolean mayInterruptIfRunning); boolean isDone(); boolean isCancelled();

一句话理解：

Future = 异步任务的“结果占位符” + 控制手柄（等待/超时/取消）

5. Future.get() 的最大坑：会阻塞当前线程

这是很多线上卡死的根源。

Future<String> f = pool.submit(() -> { Thread.sleep(5000); return "OK"; }); String r = f.get(); // 这里会阻塞 5 秒

什么时候 get 会出事？

你在Web 请求线程里 get：请求线程被卡住 → 吞吐下降
你在线程池内部的线程里 get 另一个同池任务：可能造成线程饥饿甚至“伪死锁”

经典坑：同一个线程池互相等待

ExecutorService pool = Executors.newFixedThreadPool(1); Future<String> f1 = pool.submit(() -> { Future<String> f2 = pool.submit(() -> "inner"); // 没线程可跑 return f2.get(); // 永远等不到 }); System.out.println(f1.get());

单线程池里提交嵌套任务 + get 等待 = 直接卡死。

6. 正确姿势：get(timeout) + cancel(true) + 降级

生产一定要习惯超时控制：

Future<String> f = pool.submit(() -> { Thread.sleep(5000); return "OK"; }); try { String r = f.get(2, TimeUnit.SECONDS); System.out.println("result=" + r); } catch (TimeoutException e) { System.out.println("超时，降级处理"); f.cancel(true); // 尝试中断任务 } catch (ExecutionException e) { System.out.println("执行异常: " + e.getCause()); } catch (InterruptedException e) { Thread.currentThread().interrupt(); }

注意：cancel(true)只是请求中断，任务是否能停，取决于任务是否：

响应中断（sleep/wait/阻塞 IO）
或主动检查Thread.currentThread().isInterrupted()

7. submit(Runnable) 的返回值细节：Future<?> / Future<T>

这也是容易误解的点：

submit(Runnable)

返回Future<?>，get()通常返回null

Future<?> f = pool.submit(() -> System.out.println("hi")); System.out.println(f.get()); // null

submit(Runnable, T result)

你可以指定一个固定结果（少用，但要知道）

Future<String> f = pool.submit(() -> {}, "OK"); System.out.println(f.get()); // OK

submit(Callable<T>)

返回Future<T>，get()返回计算结果

Future<Integer> f = pool.submit(() -> 42); System.out.println(f.get()); // 42

8. execute 还是 submit？怎么选（直接给你决策表）

需求	用哪个	理由
不关心返回值、只想丢给线程池跑	execute	简单直接
需要拿结果	submit(Callable)	Future.get 拿返回值
需要控制超时/取消	submit + get(timeout)	Future 才能控制
必须感知异常	execute 或 submit+get	execute 异常更“显性”；submit 需要 get
大量 fire-and-forget 任务，但又怕异常丢	execute + 统一异常捕获包装	生产推荐（第五篇方案）

一句工程建议：

业务里如果用 submit 但从不 get，那你其实就是在“主动忽略异常”。
要么 get，要么统一包装捕获异常，要么用 execute。

9. 最佳实践：把“任务提交”也工程化（承接第五篇）

在第五篇已经有 ThreadPoolManager 了，建议再加一个统一入口：

提交时强制包一层 SafeRunnable
统一打点/日志
统一命名 taskName

示例：

public static Future<?> submitSafe(ExecutorService pool, Runnable r, String taskName) { return pool.submit(() -> { try { r.run(); } catch (Throwable e) { System.err.println("[TASK-EX] " + taskName + " thread=" + Thread.currentThread().getName()); e.printStackTrace(); } }); }

这样就算你不用 get，也不会“无声失败”。