如何有效地等待多个 Future 并处理异常：CompletionService 与单个 Future 检查？

等待 Future 列表的最佳实现

异步编程提供了诸如提高响应能力和高效资源利用等好处。然而，同时管理多个 future 可能会给协调它们的完成和有效处理异常带来挑战。本文探讨了等待列表中的所有 future 都完成或其中任何一个发生异常的问题的解决方案。

简单的方法包括使用 Future.get() 单独检查每个 future。然而，这种方法对于大型列表来说效率很低，因为即使在较早的任务中发生错误，它也需要等待所有 future 完成。

另一种解决方案是使用 CompletionService。该服务提供了一个阻塞 take() 方法，允许调用者在可用时接收已完成的 future。同时，它允许在发生错误时取消正在进行的任务。

考虑以下实现：

<code class="java">Executor executor = Executors.newFixedThreadPool(4);
CompletionService<SomeResult> completionService =
    new ExecutorCompletionService<SomeResult>(executor);

// Submit 4 tasks
for (int i = 0; i < 4; i++) {
    completionService.submit(new Callable<SomeResult>() {
        public SomeResult call() {
            ... // Task logic
            return result;
        }
    });
}

int received = 0;
boolean errors = false;

// Monitor future completion and errors
while (received < 4 && !errors) {
    Future<SomeResult> resultFuture = completionService.take(); // Blocks if no futures available
    try {
        SomeResult result = resultFuture.get();
        received++;
        ... // Process result
    } catch (Exception e) {
        // Log error
        errors = true;
    }
}</code>

在此实现中，CompletionService 通过其 take() 方法接收已完成的 future 。如果任何任务抛出异常，则错误标志将设置为 true，并且循环终止。这种方法显着减少了后续任务的等待时间，从而提高了异常处理的效率。

如果需要，您可以通过在发生错误时取消任何未完成的任务来增强此解决方案，确保及时释放资源。

以上是如何有效地等待多个 Future 并处理异常：CompletionService 与单个 Future 检查？的详细内容。更多信息请关注PHP中文网其他相关文章！