怎样获取ExecutorService执行结果

在 Java 中，ExecutorService 本身只是线程池，真正获取“执行结果”通常有两种方式，取决于你提交的任务类型。

一、使用 submit() + Future 获取结果（最常用）

1️⃣ 提交 Callable（有返回值）

ExecutorService executor = Executors.newFixedThreadPool(2);

Callable<Integer> task = () -> {
    Thread.sleep(1000);
    return 1 + 1;
};

Future<Integer> future = executor.submit(task);

// 获取结果（会阻塞）
Integer result = future.get();
System.out.println(result); // 2

executor.shutdown();

✅ 特点：

• Callable 有返回值
• Future.get() 会阻塞线程直到任务完成
• 可捕获异常（ExecutionException）

2️⃣ 提交 Runnable（无返回值，但可带结果）

ExecutorService executor = Executors.newSingleThreadExecutor();

Future<String> future =
        executor.submit(() -> {
            System.out.println("run");
        }, "done");

String result = future.get();
System.out.println(result); // done

二、批量任务：invokeAll() / invokeAny()

1️⃣ invokeAll（等待所有任务完成）

List<Callable<Integer>> tasks = List.of(
        () -> 1,
        () -> 2
);

List<Future<Integer>> futures = executor.invokeAll(tasks);

for (Future<Integer> f : futures) {
    System.out.println(f.get());
}

2️⃣ invokeAny（只要一个完成就返回）

Integer result = executor.invokeAny(tasks);
System.out.println(result);

✅ 适合“竞速”场景

三、使用 CompletableFuture（推荐，更现代）

ExecutorService executor = Executors.newFixedThreadPool(2);

CompletableFuture<Integer> future =
        CompletableFuture.supplyAsync(() -> 1 + 1, executor);

future.thenAccept(System.out::println);

✅ 优点：

• 非阻塞
• 支持链式调用
• 更易处理异常和组合

四、获取异常信息

try {
    future.get();
} catch (ExecutionException e) {
    Throwable cause = e.getCause();
    cause.printStackTrace();
}

五、常见注意点 ⚠️

六、总结

如果你有具体业务场景（如超时控制、批量处理、Web 请求），我可以给你更合适的示例。