Java 中怎么用 Callable 和 Future 创建带返回值的线程-java教程-PHP中文网

java中用callable和future创建带返回值的线程，核心是实现callable接口并通过executorservice提交任务获取future对象；callable支持泛型返回值和受检异常，future.get()阻塞获取结果，invokeall可批量执行并等待全部完成。

java 中怎么用 callable 和 future 创建带返回值的线程

Java 中用 Callable 和 Future 创建带返回值的线程，核心是：不直接继承 Thread 或实现 Runnable，而是实现 Callable 接口，并通过线程池提交任务获得 Future 对象来获取结果。

1. 实现 Callable 接口（替代 Runnable）

Callable 和 Runnable 类似，但有两点关键区别：

它是一个泛型接口，Callable<string></string> 表示任务执行后返回 String 类型结果；
它的 call() 方法可以返回值，且允许抛出受检异常（Exception），而 Runnable.run() 既无返回值也不能抛受检异常。

示例：

  // 定义一个返回整数的任务
class MyTask implements Callable {
  public Integer call() throws Exception {
    Thread.sleep(1000);
    return 42;
  }
}

2. 使用 ExecutorService 提交任务并获取 Future

Future 是对异步计算结果的占位符。你不能直接“启动” Callable，必须借助 ExecutorService（如 Executors.newFixedThreadPool(1)）来执行：

Alibabacloud Sdk Client Initialization For Java

在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。

下载

submit(Callable) 方法返回 Future<t></t>；
调用 future.get() 会阻塞当前线程，直到任务完成并返回结果；
get(long, TimeUnit) 可设置超时，避免无限等待；
如果任务执行中抛出异常，get() 会以 ExecutionException 包装后抛出。

完整调用示例：

  // 创建线程池
ExecutorService executor = Executors.newFixedThreadPool(1);
  // 提交 Callable 任务
Future future = executor.submit(new MyTask());
  // 获取结果（会阻塞）
try {
  Integer result = future.get();
  System.out.println("结果：" + result);
} catch (InterruptedException | ExecutionException e) {
  e.printStackTrace();
} finally {
  executor.shutdown();
}

3. 多个 Callable 任务批量处理（用 invokeAll）

如果你有多个 Callable，想等全部完成再统一取结果，可用 invokeAll()：

它接收 Collection extends Callable<t>></t>，返回 List<future>></future>；
该方法会阻塞，直到所有任务完成（或超时）；
遍历返回的 Future 列表，逐个调用 get() 即可拿到每个结果。

示例片段：

List> tasks = Arrays.asList(
  () -> { Thread.sleep(500); return "A"; },
  () -> { Thread.sleep(300); return "B"; }
);
List> futures = executor.invokeAll(tasks);
for (Future f : futures) {
  System.out.println(f.get());
}