CompletableFuture在超时后返回所有完成的结果

Question

我想有一个清单的comletablefutures我想等待。带有以下代码。

  public static <T> CompletableFuture<List<T>> finishAllQuery(
  List<CompletableFuture<T>> futures) {
CompletableFuture<Void> allDoneFuture =
    CompletableFuture.allOf(futures.toArray(new CompletableFuture[futures.size()]));
return allDoneFuture.thenApply(
    v -> futures.stream().filter(Objects::nonNull)
        .map(future -> future.join())
        .collect(Collectors.toList())
);
  }
CompletableFuture<List<Result>> allResponse = finishAllQuery(futures);
allResponse.get(5, milliseconds)

问题是，在所有的期货，其中一些可以是缓慢的，我想在到期时间后，get方法返回与所有完成的结果。有办法做到这一点吗？

多谢.

Answer 1

如果您不一定希望所有期货都完成，那么您不应该使用allof()。您可以使用CompletionService，然后使用带有timeout的poll（）方法。于是流将是：

1. 将ExcecutorService包装在CompletionService中
2. 向CompletionService提交N个任务。然后轮询有超时的单个任务。类似于:

elapsedTime=0；可用时间=5ms；completedFutures=列表（）；

while (elapsedTime < availableTime):
    remainingTime = availableTime - elapsedTime; 
    startTime = currentTime();
    completedFutures.add(CompletionService.poll(timeout=remainingTime));
    elapsedTime += (currentTime() - startTime)