如何在 Java 中有效管理 Futures 列表并处理异常？

通过异常处理高效管理 Future 列表

在 Java 中，使用 future 时，可能会遇到需要等待未来任务列表完成的情况处理出现的任何异常情况时。一个简单的方法是依次等待每个 future 并检查潜在的异常。但是，如果列表中较早发生异常，则这种方法会遇到效率问题，因为后续任务仍会不必要地等待。

为了解决此问题，另一种解决方案利用 CompletionService 类。 CompletionService 在 future 可用时接收它们，并允许在遇到异常时提前终止。

下面提供了如何实现此方法的示例：

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

// 4 tasks
for (int i = 0; i &lt; 4; i++) {
    completionService.submit(new Callable&lt;SomeResult&gt;() {
        public SomeResult call() {
            // ... task implementation
            return result;
        }
    });
}

int received = 0;
boolean errors = false;

while (received &lt; 4 &amp;&amp; !errors) {
    Future&lt;SomeResult&gt; resultFuture = completionService.take(); // Blocks if none available
    try {
        SomeResult result = resultFuture.get();
        received++;
        // ... do something with the result
    } catch (Exception e) {
        // Log the exception
        errors = true;
    }
}

// Potentially consider canceling any still running tasks if errors occurred</code>

通过利用 CompletionService ，您可以高效地等待未来任务完成，同时及时处理异常。

以上是如何在 Java 中有效管理 Futures 列表并处理异常？的详细内容。更多信息请关注PHP中文网其他相关文章！