高效等待期货列表

处理期货列表时，目标是等到完成或发生任何未来都是例外。如果早期发生异常，涉及单独调用 f.get() 的简单方法可能会导致不必要的等待。

使用 CompletionService 避免不必要的等待

解决此问题问题，CompletionService 类开始发挥作用。它允许执行异步任务，并在其结果可用时以线程安全的方式检索它们的结果。使用方法如下：

Executor executor = Executors.newFixedThreadPool(4);
CompletionService completionService = new ExecutorCompletionService(executor);

// Submit tasks to the service
for (int i = 0; i () {
        @Override
        public SomeResult call() {
            // Task logic here
            return result;
        }
    });
}

int received = 0;
boolean errors = false;

// Loop until all tasks are complete or an error occurs
while (received  resultFuture = completionService.take(); // Blocks if nothing available
    try {
        SomeResult result = resultFuture.get();
        received  ;
        // Process result here
    } catch (Exception e) {
        // Log error
        errors = true;
    }
}

// Consider canceling remaining tasks if an error occurred

通过使用CompletionService方法，您可以实时监控任务的完成情况，如果发生错误，则停止进一步处理，从而避免不必要的等待。