应使用Callable接口结合Future和ExecutorService获取线程返回结果。1. Callable的call()方法可返回值并抛出异常；2. 通过ExecutorService提交Callable任务获得Future对象，调用future.get()阻塞获取结果；3. 可设置future.get(超时时间)避免无限等待，超时抛TimeoutException，任务异常封装为ExecutionException；4. 可批量提交多个Callable任务，用List保存Future，遍历获取结果并汇总。该方式比手动管理线程更安全高效。
在Java中，如果需要线程执行完成后返回结果，就不能使用只支持void run()的Runnable接口。这时应该使用Callable接口，它允许任务返回值，并可抛出异常。结合Future和ExecutorService，可以方便地获取线程的执行结果。
1. Callable接口的基本用法
Callable是一个泛型接口，只有一个方法V call()，可以返回指定类型的值，也可以抛出异常。
import java.util.concurrent.Callable;
<p>public class MyTask implements Callable<String> {
@Override
public String call() throws Exception {
Thread.sleep(2000);
return "Hello from thread: " + Thread.currentThread().getName();
}
}
2. 使用ExecutorService提交Callable任务
通过线程池的submit()方法提交Callable任务，会返回一个Future对象，用于获取结果。
import java.util.concurrent.*;
<p>public class CallableExample {
public static void main(String[] args) {
ExecutorService executor = Executors.newSingleThreadExecutor();</p><pre class="brush:php;toolbar:false;"> Callable<String> task = new MyTask();
Future<String> future = executor.submit(task);
try {
System.out.println("等待结果...");
String result = future.get(); // 阻塞直到结果返回
System.out.println("结果: " + result);
} catch (InterruptedException | ExecutionException e) {
e.printStackTrace();
} finally {
executor.shutdown();
}
}
}
3. 处理超时和异常情况
调用future.get()可能长时间阻塞，可以使用带超时的版本避免无限等待。
立即学习“Java免费学习笔记（深入）”；
- future.get(3, TimeUnit.SECONDS)：最多等待3秒，超时抛出TimeoutException
- 任务内部异常会封装在ExecutionException中
- 线程中断会抛出InterruptedException
示例：设置超时时间
try {
String result = future.get(1, TimeUnit.SECONDS);
} catch (TimeoutException e) {
System.out.println("任务执行超时");
future.cancel(true); // 可选择取消任务
}
4. 多个任务并发执行并汇总结果
可以提交多个Callable任务，使用List保存Future对象，统一处理结果。
ExecutorService executor = Executors.newFixedThreadPool(3);
List<Future<Integer>> futures = new ArrayList<>();
<p>for (int i = 1; i <= 5; i++) {
final int taskId = i;
Callable<Integer> task = () -> {
Thread.sleep(1000);
return taskId * 2;
};
futures.add(executor.submit(task));
}</p><p>int sum = 0;
for (Future<Integer> f : futures) {
sum += f.get();
}
System.out.println("总和: " + sum);
executor.shutdown();
基本上就这些。Callable配合Future和线程池，是Java中实现有返回值多线程任务的标准方式，比手动管理线程更安全高效。
