callable 是支持返回值和受检异常的泛型接口，通过 callable 定义任务、submit() 返回 future 获取结果，配合 invokeall() 和超时处理可安全执行并收集多种类型异步任务。
callable 是 java 并发包中用于替代 runnable 的接口，核心优势在于它支持返回值和抛出受检异常。它天然支持泛型，通过类型参数 v 指定返回值类型，配合 executorservice 可以轻松实现带结果的多线程任务。
定义泛型 Callable 任务
直接实现 Callable<v></v> 接口，其中 V 是你期望的返回类型（如 String、Integer、自定义对象等）。重写 call() 方法，在其中编写耗时逻辑并返回对应类型的值：
Callable<integer> task = () -> {
Thread.sleep(1000); // 模拟耗时操作
return 42; // 返回 Integer 类型值
};
</integer>
也可以写成独立类形式，便于复用和测试：
public class SumTask implements Callable<long> {
private final int start, end;
public SumTask(int start, int end) {
this.start = start;
this.end = end;
}
@Override
public Long call() throws Exception {
long sum = 0;
for (int i = start; i
</long>
提交任务并获取泛型返回结果
使用 ExecutorService.submit() 提交 Callable，它会立即返回一个 Future<v></v>。这个 Future 的泛型类型与 Callable 一致，编译器能准确推断，无需强制转换：
ExecutorService executor = Executors.newFixedThreadPool(2);
// 提交任务，得到 Future<integer>
Future<integer> future = executor.submit(task);
try {
Integer result = future.get(); // 阻塞等待，返回 Integer 类型
System.out.println("Result: " + result);
} catch (InterruptedException | ExecutionException e) {
e.printStackTrace();
}
executor.shutdown();
</integer></integer>
批量提交多种泛型 Callable 并安全收集结果
当需要并行执行多个不同返回类型的任务（比如一个查数据库返回 User，一个调用 API 返回 Order），可分别定义对应泛型的 Callable，统一用 invokeAll() 或逐个 submit()：
- 每个
Callable独立声明自己的泛型，互不影响 - 推荐用
List<future>></future>存储结果，避免类型擦除导致的隐患 - 调用
future.get()时，返回值类型由泛型声明保证，IDE 和编译器全程校验
Callable<user> userTask = () -> fetchUserById(123);
Callable<list>> orderTask = () -> fetchOrdersByUserId(123);
List<future>> futures = executor.invokeAll(
Arrays.asList(userTask, orderTask)
);
// 分别获取（注意类型安全）
User user = ((Future<user>) futures.get(0)).get();
List<order> orders = ((Future<list>>) futures.get(1)).get();
</list></order></user></future></list></user>
处理异常与超时更安全
Callable.call() 允许抛出任意异常（包括受检异常），这些异常会被包装进 ExecutionException，在 future.get() 中统一抛出。建议显式处理：
- 用
future.get(timeout, unit)避免无限等待 - 捕获
ExecutionException获取原始异常（e.getCause()） - 捕获
TimeoutException和CancellationException做针对性处理
try {
String result = future.get(3, TimeUnit.SECONDS);
} catch (TimeoutException e) {
System.err.println("Task timed out");
future.cancel(true); // 中断执行线程
} catch (ExecutionException e) {
Throwable cause = e.getCause();
System.err.println("Task failed: " + cause.getMessage());
}
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
