如何在Java中使用Callable和Future-java教程-PHP中文网

Callable用于执行有返回值和异常的异步任务，Future用于获取结果和控制任务生命周期，二者结合ExecutorService实现灵活的并发管理。

如何在java中使用callable和future

Callable允许任务返回结果并抛出异常，而Future则用于获取这些异步任务的结果，并控制其生命周期。它们是Java并发编程中处理有返回值的异步操作的关键工具，为我们提供了一种更灵活、更强大的方式来管理并发任务。

解决方案

要在Java中使用Callable和Future，核心思想是利用ExecutorService来提交Callable任务，然后通过返回的Future对象来管理和获取任务的结果。这个过程可以分解为几个步骤，我通常会这样来组织我的代码：

定义一个Callable任务： 创建一个实现java.util.concurrent.Callable接口的类。这个接口有一个call()方法，它会返回一个泛型类型的结果，并且可以抛出Exception。这是它与Runnable最大的不同，也是其强大之处。

import java.util.concurrent.Callable;
import java.util.Random;

class MyCallableTask implements Callable<Integer> {
    private String taskName;

    public MyCallableTask(String taskName) {
        this.taskName = taskName;
    }

    @Override
    public Integer call() throws Exception {
        System.out.println(taskName + " 正在执行...");
        Thread.sleep(new Random().nextInt(3000)); // 模拟耗时操作
        int result = new Random().nextInt(100);
        if (result < 10) {
            throw new RuntimeException(taskName + " 遇到了一个随机错误！");
        }
        System.out.println(taskName + " 执行完毕，结果是: " + result);
        return result;
    }
}

登录后复制

创建ExecutorService： ExecutorService是执行异步任务的框架。你可以使用Executors工厂类来创建不同类型的线程池，比如newFixedThreadPool、newCachedThreadPool等。选择哪种线程池取决于你的应用场景。

立即学习“Java免费学习笔记（深入）”；
```
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
// ...
ExecutorService executor = Executors.newFixedThreadPool(2); // 创建一个固定大小的线程池
```
登录后复制
提交Callable任务并获取Future： 使用ExecutorService的submit()方法提交你的Callable实例。这个方法会立即返回一个Future对象。请注意，submit()是非阻塞的，它只是把任务放入了线程池的队列，任务本身可能还没有开始执行。
```
import java.util.concurrent.Future;
// ...
Future<Integer> future1 = executor.submit(new MyCallableTask("任务A"));
Future<Integer> future2 = executor.submit(new MyCallableTask("任务B"));
```
登录后复制

使用Future获取结果或管理任务： Future对象是异步操作结果的句柄。你可以通过它来：

get(): 阻塞式地等待任务完成并获取其结果。如果任务抛出异常，get()会抛出ExecutionException。
get(long timeout, TimeUnit unit): 在指定时间内等待任务完成并获取结果。如果超时，会抛出TimeoutException。
isDone(): 检查任务是否已经完成（正常完成、异常结束或被取消）。
isCancelled(): 检查任务是否被取消。
cancel(boolean mayInterruptIfRunning): 尝试取消任务。

try {
    System.out.println("尝试获取任务A的结果...");
    Integer result1 = future1.get(); // 阻塞直到任务A完成
    System.out.println("任务A的结果: " + result1);

    System.out.println("尝试获取任务B的结果...");
    // 尝试在5秒内获取任务B的结果
    Integer result2 = future2.get(5, java.util.concurrent.TimeUnit.SECONDS);
    System.out.println("任务B的结果: " + result2);
} catch (java.util.concurrent.InterruptedException e) {
    Thread.currentThread().interrupt(); // 重新设置中断标志
    System.err.println("等待任务时线程被中断: " + e.getMessage());
} catch (java.util.concurrent.ExecutionException e) {
    System.err.println("任务执行过程中发生异常: " + e.getCause().getMessage());
} catch (java.util.concurrent.TimeoutException e) {
    System.err.println("等待任务超时: " + e.getMessage());
    future2.cancel(true); // 如果超时，尝试取消任务B
} finally {
    executor.shutdown(); // 关闭线程池
    System.out.println("ExecutorService 已关闭。");
}

登录后复制

关闭ExecutorService： 当所有任务都提交并处理完毕后，记得调用executor.shutdown()来平稳地关闭线程池。这会阻止新的任务提交，并允许已提交的任务执行完毕。如果需要立即停止所有正在运行的任务，可以使用executor.shutdownNow()。

Callable与Runnable有何不同，我该何时选择它们？

在我看来，这是Java并发编程初学者最常遇到的一个问题，也是理解Callable价值的关键。简单来说，Runnable和Callable都代表一个可以在单独线程中执行的任务，但它们之间存在几个核心差异，决定了你在不同场景下的选择。

Runnable的特点：

无返回值： Runnable接口的run()方法没有返回值（void）。这意味着你不能直接从run()方法中获取任务执行的结果。
不能抛出受检异常： run()方法签名中没有throws Exception，所以它不能直接抛出受检异常。如果任务内部发生受检异常，你必须在run()方法内部捕获并处理它，或者将其包装成非受检异常（如RuntimeException）抛出。
用途： 通常用于“执行并忘记”的任务，或者任务的目的是修改某个共享状态，而不是返回一个计算结果。比如，一个后台日志记录任务，或者一个定期清理缓存的任务。

Callable的特点：

有返回值： Callable接口的call()方法返回一个泛型类型V的结果。这个结果可以通过Future对象在任务完成后获取。
可以抛出受检异常： call()方法签名包含throws Exception，允许你直接抛出受检异常，这些异常会被Future.get()方法包装在ExecutionException中再次抛出。
用途： 当你的任务需要执行一个计算并返回一个结果时，或者任务在执行过程中可能会遇到需要向上层报告的受检异常时，Callable是更合适的选择。例如，一个从数据库查询数据并返回结果的任务，或者一个执行复杂计算的任务。

何时选择：

选择Runnable：
- 当任务不需要返回任何结果时。
- 当任务只是执行一些操作，比如更新数据库、发送消息、执行IO操作，并且结果不是必需的。
- 当任务内部的异常可以在任务自身内部完全处理时。
选择Callable：
- 当任务需要返回一个计算结果时。
- 当任务在执行过程中可能抛出受检异常，并且你希望这些异常能够被调用者捕获和处理时。
- 当你需要更精细地控制任务的生命周期，例如取消任务或检查任务是否完成时（虽然Future也可以用于Runnable，但结合Callable的返回值特性，其作用更为凸显）。

在实践中，如果我需要一个异步任务来帮我计算点什么，或者从某个地方获取数据，我几乎总是倾向于使用Callable。即便有时任务看起来没有直接的“结果”，但能够抛出异常并让外部感知到，这本身就是一种宝贵的“结果”信息。

处理Future任务时，常见的陷阱和异常有哪些？

在使用Future处理异步任务时，虽然它带来了极大的便利，但也伴随着一些需要我们特别留意的陷阱和异常。我遇到过不少开发者因为对这些细节理解不足而踩坑。

InterruptedException：
- 何时发生： 当线程在等待Future.get()返回结果时，如果当前线程被中断，就会抛出此异常。这通常发生在应用程序需要优雅地关闭，或者某个操作需要被取消时。
- 处理方式： 捕获InterruptedException后，最佳实践是重新设置当前线程的中断状态（Thread.currentThread().interrupt()），因为捕获异常会清除中断标志。然后，根据业务逻辑决定是继续执行还是终止当前操作。
ExecutionException：
- 何时发生： 这是最常见的异常之一。当Callable任务内部抛出任何异常（包括运行时异常和受检异常）时，Future.get()方法都会将其包装成ExecutionException抛出。
- 处理方式： ExecutionException有一个getCause()方法，可以获取到Callable任务内部实际抛出的异常。你需要捕获ExecutionException，然后通过getCause()来获取并处理真正的业务异常。这就像剥洋葱一样，你需要一层层地剥开才能看到核心。
TimeoutException：
- 何时发生： 当你使用Future.get(long timeout, TimeUnit unit)方法，并且任务在指定的时间内未能完成时，就会抛出此异常。
- 处理方式： 捕获TimeoutException后，你可以选择记录日志、向用户提示任务超时、或者尝试取消任务（future.cancel(true)）以释放资源。这对于需要响应时间限制的系统非常重要。
CancellationException：
- 何时发生： 如果任务在执行前或执行中被future.cancel()方法取消，那么当调用future.get()时，就会抛出CancellationException。
- 处理方式： 通常，如果任务被取消，我们可能不需要其结果，所以捕获此异常后通常是进行一些清理工作或日志记录。
Future.get()的阻塞特性：

如知AI笔记
如知笔记——支持markdown的在线笔记，支持ai智能写作、AI搜索，支持DeepseekR1满血大模型

27

查看详情
- 陷阱： get()方法是阻塞的。如果在一个单线程环境或主线程中不加思索地调用get()，并且任务执行时间很长，那么整个应用程序可能会被阻塞，导致UI无响应或系统吞吐量下降。
- 避免： 尽量在单独的线程中调用get()，或者使用get(timeout, unit)来避免无限期等待。更高级的异步编程模型，如CompletableFuture，提供了非阻塞的结果处理机制，可以显著改善这个问题。
ExecutorService未关闭：
- 陷阱： 如果不调用executorService.shutdown()或shutdownNow()，线程池中的线程可能会一直存活，阻止应用程序正常退出，甚至导致资源泄露。
- 避免： 务必在所有任务提交并处理完毕后，或者在应用程序关闭时，调用shutdown()来优雅地关闭线程池。通常我会把它放在finally块中，确保无论任务执行成功与否，线程池都能被关闭。

理解并妥善处理这些异常和陷阱，是编写健壮、高效Java并发代码的关键。

如何更优雅地管理和组合多个Callable任务的结果？

当我们面对的不是单个Callable任务，而是需要同时执行多个任务，并对它们的结果进行聚合或按完成顺序处理时，Future的基础用法可能就不那么“优雅”了。Java并发API提供了一些更高级的工具来处理这类场景，帮助我们更好地管理和组合多个Callable任务。

使用ExecutorService.invokeAll()：

用途： 当你需要提交一组Callable任务，并等待所有任务都完成（或超时）后，一次性获取所有任务的Future列表时，invokeAll()非常方便。
特点： 它会阻塞当前线程，直到所有任务都完成，或者指定的超时时间到达。返回的List<Future<T>>的顺序与你提交的Callable列表的顺序是一致的。

示例：

List<Callable<Integer>> tasks = new ArrayList<>();
tasks.add(new MyCallableTask("批量任务1"));
tasks.add(new MyCallableTask("批量任务2"));
tasks.add(new MyCallableTask("批量任务3"));

ExecutorService executor = Executors.newFixedThreadPool(3);
try {
    List<Future<Integer>> futures = executor.invokeAll(tasks, 10, java.util.concurrent.TimeUnit.SECONDS);
    System.out.println("所有批量任务提交完毕，开始获取结果...");
    for (int i = 0; i < futures.size(); i++) {
        Future<Integer> future = futures.get(i);
        try {
            if (future.isDone()) {
                System.out.println("批量任务" + (i + 1) + " 的结果: " + future.get());
            } else {
                System.out.println("批量任务" + (i + 1) + " 未在规定时间内完成。");
            }
        } catch (ExecutionException e) {
            System.err.println("批量任务" + (i + 1) + " 执行异常: " + e.getCause().getMessage());
        }
    }
} catch (InterruptedException | TimeoutException e) {
    System.err.println("批量任务执行中断或超时: " + e.getMessage());
} finally {
    executor.shutdown();
}

登录后复制

思考： invokeAll()的缺点是，即使第一个任务很快完成，你也必须等待所有任务都完成才能开始处理结果。如果任务之间没有强依赖，或者你希望尽快处理已完成的任务，这可能不是最优解。

使用ExecutorService.invokeAny()：
- 用途： 如果你有一组Callable任务，并且只需要其中任何一个任务成功完成的结果，那么invokeAny()是你的选择。它会提交所有任务，并返回最快完成的那个任务的结果，然后取消其他所有未完成的任务。
- 特点： 阻塞直到至少一个任务完成。
- 思考： 这种模式适用于冗余计算、竞速获取结果的场景。
使用CompletionService：
- 用途： 这是我个人认为在处理多个Callable任务时最“优雅”的方式之一，特别是当你希望以任务完成的顺序来处理结果时。CompletionService将ExecutorService和BlockingQueue的功能结合起来。
- 工作原理： 你将Callable任务提交给CompletionService，它会在内部将任务提交给ExecutorService执行。当任务完成时，其对应的Future对象会被放入一个内部的BlockingQueue。你可以通过调用CompletionService.take()或poll()方法，按任务完成的顺序获取这些Future对象。
- 优点： 解决了invokeAll()需要等待所有任务完成的痛点，你可以实时处理已完成的任务结果。
- 示例：
```
import java.util.concurrent.CompletionService;
import java.util.concurrent.ExecutorCompletionService;
// ...
ExecutorService executor = Executors.newFixedThreadPool(3);
CompletionService<Integer> completionService = new ExecutorCompletionService<>(executor);

completionService.submit(new MyCallableTask("CS任务1"));
completionService.submit(new MyCallableTask("CS任务2"));
completionService.submit(new MyCallableTask("CS任务3"));

for (int i = 0; i < 3; i++) {
    try {
        Future<Integer> future = completionService.take(); // 阻塞直到有任务完成
        System.out.println("一个CS任务完成，结果: " + future.get());
    } catch (InterruptedException | ExecutionException e) {
        System.err.println("CS任务执行异常: " + e.getCause().getMessage());
    }
}
executor.shutdown();
```
  登录后复制
- 思考： CompletionService非常适合那些任务执行时间不确定，且你希望尽快处理已完成结果的场景，比如网络爬虫、分布式计算中的子任务。
CompletableFuture (简要提及)：
- 虽然Callable和Future是Java并发的基础，但Java 8引入的CompletableFuture提供了一种更强大、更灵活、更具函数式编程风格的方式来处理异步任务。它允许你以非阻塞的方式链式调用、组合多个异步操作，并且提供了更丰富的异常处理机制。
- 如果你的项目允许使用Java 8及更高版本，并且需要更复杂的异步流程控制和结果组合，那么我强烈建议深入学习CompletableFuture。它在很多方面超越了传统的Future，提供了更现代的异步编程体验。