Java中用Callable处理多线程返回结果的关键在于高效安全地获取结果：通过ExecutorService提交Callable任务获得Future，务必设置超时调用get()，批量任务优先用ExecutorCompletionService按完成顺序取结果，并及时关闭线程池防止资源泄漏。
Java 中用 Callable 处理多线程返回结果，关键不在“写接口”，而在于“怎么拿结果更稳、更及时、更少阻塞”。核心是把任务定义、提交、取值、异常和生命周期四件事串起来，避免主线程傻等或资源泄漏。
用 Callable 定义可返回的任务
Callable 是泛型接口，call() 方法必须有返回值，且能抛出受检异常——这点比 Runnable 更贴近真实业务逻辑（比如查数据库、调 HTTP、解析文件）。
- 直接用 Lambda 写简单任务： Callable<Integer> task = () -> { Thread.sleep(500); return 42; };
- 复杂逻辑建议单独实现类，方便复用和测试，泛型类型即最终结果类型（如 Callable<List<User>>）
- 不要在 call() 里吞掉异常；受检异常会自动包装进 ExecutionException，后续 get() 时统一处理
通过 ExecutorService 提交并获取 Future
别手动 new Thread + FutureTask，现代写法一律走线程池 submit()。它返回 Future，代表“尚未就绪但终将到来的结果”。
- 用 exec.submit(task) 提交，立刻拿到 Future 对象，不阻塞
- Future.get() 默认无限等待，生产环境务必带超时：future.get(3, TimeUnit.SECONDS)，超时抛 TimeoutException
- get() 抛出的 ExecutionException 是包装器，真正异常在 getCause() 里，记得 unwrap 处理
批量任务结果获取要避免顺序等待
如果提交了 10 个任务，但第 1 个最慢，按 List 索引逐个 get() 就会让后面更快完成的任务白白等待——这很常见，也很浪费。
立即学习“Java免费学习笔记（深入）”；
- 用 invokeAll(tasks, timeout, unit) 一次性提交并限时等待全部完成，返回 Future 列表
- 更推荐 ExecutorCompletionService：内部用 BlockingQueue 缓存已完成任务，take() 或 poll() 拿到的是“最先完成的那个”，天然支持结果驱动的后续处理
- 不需要所有结果？用 invokeAny(tasks)，任意一个成功就返回，适合冗余调用或降级场景
别忘了线程池和资源收尾
Future 本身不管理线程，线程池才是执行载体。漏关池子会导致内存泄漏、端口占满、应用无法优雅停机。
- 任务提交完，调 exec.shutdown() 停止接收新任务
- 配合 exec.awaitTermination() 等待已有任务结束，超时则 exec.shutdownNow() 强制中断
- Future 对象不用显式销毁，但长期持有未 get() 的 Future 可能阻碍 GC（尤其大对象结果）
