Callable比Runnable更适合需要返回结果的线程任务，其call()方法可返回值并抛出异常，结合Future和线程池可获取执行结果；通过submit()提交任务获取Future对象，调用get()方法阻塞等待结果，支持超时控制与异常处理，适用于并行数据查询、批量文件处理和分片计算等场景。
在Java中，如果需要创建一个可以返回结果的线程任务，Callable 是比 Runnable 更合适的选择。与 Runnable 的 run() 方法不同，Callable 的 call() 方法允许返回值，并能抛出异常，配合 Future 和线程池使用，非常适合处理并发中需要获取执行结果的场景。
Callable 与 Future 基本用法
Callable 是一个泛型接口，call() 方法返回指定类型的值。要获取这个返回值，需要结合 Future 对象使用。通常通过线程池（ExecutorService）提交 Callable 任务，得到一个 Future 实例，用于后续获取结果。
示例代码：
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
<p>public class CallableExample {
public static void main(String[] args) throws Exception {
ExecutorService executor = Executors.newSingleThreadExecutor();</p><pre class='brush:java;toolbar:false;'> // 定义一个 Callable 任务
Callable<Integer> task = () -> {
System.out.println("正在执行计算...");
Thread.sleep(2000);
return 42; // 返回结果
};
// 提交任务，返回 Future 对象
Future<Integer> future = executor.submit(task);
System.out.println("等待结果...");
Integer result = future.get(); // 阻塞直到结果返回
System.out.println("结果是：" + result);
executor.shutdown();
}
}
立即学习“Java免费学习笔记（深入）”；
在这个例子中，call() 方法返回一个 Integer 类型的值，future.get() 会阻塞主线程直到任务完成。
多任务并发并收集结果
实际开发中，常常需要并发执行多个任务并汇总结果。可以使用 invokeAll() 方法批量提交 Callable 列表，获取一组 Future 对象。
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.*;
<p>public class MultiCallableExample {
public static void main(String[] args) throws Exception {
ExecutorService executor = Executors.newFixedThreadPool(3);
List<Callable<String>> tasks = new ArrayList<>();</p><pre class='brush:java;toolbar:false;'> // 添加多个任务
for (int i = 1; i <= 3; i++) {
final int taskId = i;
tasks.add(() -> {
System.out.println("任务 " + taskId + " 开始");
Thread.sleep(1000 * taskId);
return "任务 " + taskId + " 完成";
});
}
// 批量提交任务
List<Future<String>> futures = executor.invokeAll(tasks);
// 获取每个任务的结果
for (Future<String> future : futures) {
System.out.println(future.get());
}
executor.shutdown();
}
}
立即学习“Java免费学习笔记（深入）”；
invokeAll() 会阻塞，直到所有任务都完成。适合需要等待全部结果的场景。
超时控制与异常处理
在生产环境中，不能让程序无限等待。Future 的 get() 方法支持设置超时时间，避免长时间阻塞。
try {
String result = future.get(3, TimeUnit.SECONDS); // 最多等3秒
} catch (TimeoutException e) {
System.out.println("任务超时");
future.cancel(true); // 可选择中断任务
} catch (InterruptedException | ExecutionException e) {
System.out.println("任务执行出错：" + e.getMessage());
}
ExecutionException 包装了 call() 方法中抛出的异常，需注意解包处理。cancel(true) 可尝试中断正在执行的任务。
Callable 在实际项目中的应用场景
Callable 特别适用于以下场景：
- 并行数据查询：从多个数据库或API并行拉取数据，汇总后返回
- 批量文件处理：多个文件同时解析，返回各自处理结果
- 分片计算任务：如大数分解、图像处理等可拆分任务
配合 CompletionService 使用，还能实现“谁先完成谁先处理”的高效模式，提升响应速度。
基本上就这些。Callable + Future + 线程池的组合，是Java并发编程中实现带返回值任务的标准做法，掌握它对处理复杂业务逻辑很有帮助。
