在Java 中，使用future 時，可能會遇到需要等待未來任務清單完成的情況處理出現的任何異常情況時。一個簡單的方法是依次等待每個 future 並檢查潛在的異常。但是，如果清單中較早發生異常，則這種方法會遇到效率問題，因為後續任務仍會不必要地等待。
為了解決這個問題，另一個解決方案利用 CompletionService 類別。 CompletionService 在 future 可用時接收它們，並允許在遇到異常時提前終止。
以下提供如何實現此方法的範例：
<code class="java">Executor executor = Executors.newFixedThreadPool(4);
CompletionService<SomeResult> completionService = new ExecutorCompletionService<>(executor);
// 4 tasks
for (int i = 0; i < 4; i++) {
completionService.submit(new Callable<SomeResult>() {
public SomeResult call() {
// ... task implementation
return result;
}
});
}
int received = 0;
boolean errors = false;
while (received < 4 && !errors) {
Future<SomeResult> 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中文網其他相關文章！
