Callable 是支持返回值和受检异常的泛型接口，通过 Callable<V> 定义任务、submit() 返回 Future<V> 获取结果，配合 invokeAll() 和超时处理可安全执行并收集多种类型异步任务。
callable 是 java 并发包中用于替代 runnable 的接口，核心优势在于它支持返回值和抛出受检异常。它天然支持泛型，通过类型参数 v 指定返回值类型，配合 executorservice 可以轻松实现带结果的多线程任务。
定义泛型 Callable 任务
直接实现 Callable<V> 接口，其中 V 是你期望的返回类型（如 String、Integer、自定义对象等）。重写 call() 方法，在其中编写耗时逻辑并返回对应类型的值：
Callable<Integer> task = () -> {
Thread.sleep(1000); // 模拟耗时操作
return 42; // 返回 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 <= end; i++) {
sum += i;
}
return sum; // 自动装箱为 Long
}
}
提交任务并获取泛型返回结果
使用 ExecutorService.submit() 提交 Callable，它会立即返回一个 Future<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();
批量提交多种泛型 Callable 并安全收集结果
当需要并行执行多个不同返回类型的任务（比如一个查数据库返回 User，一个调用 API 返回 Order），可分别定义对应泛型的 Callable，统一用 invokeAll() 或逐个 submit()：
立即学习“Java免费学习笔记（深入）”；
- 每个
Callable独立声明自己的泛型，互不影响 - 推荐用
List<Future<T>>存储结果，避免类型擦除导致的隐患 - 调用
future.get()时，返回值类型由泛型声明保证，IDE 和编译器全程校验
Callable<User> userTask = () -> fetchUserById(123);
Callable<List<Order>> 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<Order>>) futures.get(1)).get();
处理异常与超时更安全
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());
}
