Callable 是带返回值和异常处理能力的异步任务接口，需配合 ExecutorService 和 Future 实现并行；其核心优势为返回泛型结果、支持 throws 异常、适配 Lambda 表达式。
Callable 接口本身不直接实现并行，它只是定义了一个可返回结果、可抛异常的任务单元；真正实现并行执行，需要配合线程池（ExecutorService）和 Future 机制来调度多个 Callable 任务并发运行。
Callable 是什么：带返回值的异步任务模板
Callable 是一个函数式接口，泛型参数 V 表示任务执行后的返回类型。相比 Runnable，它的核心优势在于：
- 有返回值：call() 方法返回具体结果（如 Integer、String 或自定义对象）
- 可抛异常：支持 throws Exception，能更自然地处理受检异常
-
天然适配 Lambda：可直接用箭头表达式写任务逻辑，例如
() -> doSomething()
并行执行的关键组合：ExecutorService + submit() + Future
单靠 Callable 无法并行，必须交由线程池统一管理。典型流程如下：
- 创建固定大小或缓存型线程池，例如
Executors.newFixedThreadPool(4) - 调用
executor.submit(callable)提交任务，立即返回 Future 对象 - Future 就像“取货单”：不阻塞主线程，后续用
get()拿结果（会阻塞直到完成） - 多个 submit 可同时发出，线程池自动分配空闲线程并发执行
实际并行场景示例：批量接口调用
比如要同时查三个外部服务：
Java Maven Common
下载
Java Maven 项目审查工作流的通用输入处理。当 Java Maven 项目以 ZIP压缩包或 GitLab 仓库 URL 形式提供且需要...时使用。
立即学习“Java免费学习笔记（深入）”；
ExecutorService pool = Executors.newFixedThreadPool(3);
List<Future<String>> futures = Arrays.asList(
pool.submit(() -> httpGet("https://api.a.com")),
pool.submit(() -> httpGet("https://api.b.com")),
pool.submit(() -> httpGet("https://api.c.com"))
);
// 非阻塞等待全部完成
List<String> results = futures.stream()
.map(future -> { try { return future.get(); } catch (Exception e) { return null; } })
.collect(Collectors.toList());
pool.shutdown(); // 记得关闭线程池
若每个接口耗时 1 秒，串行需 3 秒，并行通常接近 1 秒（忽略调度开销）。
注意线程安全与资源控制
并行不等于随意并发，需关注：
- 线程池大小要合理：CPU 密集型任务建议线程数 ≈ CPU 核心数；IO 密集型可适当放大（如 2×核数）
- 避免共享可变状态：Callable 实例间不要共用非线程安全对象（如 ArrayList、SimpleDateFormat）
-
超时与异常兜底：用
future.get(5, TimeUnit.SECONDS)防止某个任务卡死拖垮整体 -
及时释放资源：调用
shutdown()或shutdownNow()，避免线程泄漏
