等待两个 Futures/Runnables/Callables 中的任何一个完成？

Question

如何一次将两个任务添加到 Executor（或类似的），然后等待两个中的任何一个完成（即最快），而另一个以及之前启动的任务继续在后台？

我知道 CompletionService 提供了类似的东西，但我能做的就是等待下一个完成，.take()。在我的情况下，这可能来自以前的计划，而不是我需要等待的计划之一。

我想要的伪代码

ExecutorService executorService = Executors.newFixedThreadPool(100);
Future<?> one = executorService.submit(() -> oneWay());
Future<?> two = executorService.submit(() -> orAnother());

Future theFirstOneToFinish = waitFor(one, two);
// one done, the other one keeps on working
return theFirstOneToFinish;

Answer 1

CompletionService 仅监督它提交的那些任务。换句话说，您可以为您提交的每对任务创建一个新任务，然后调用take() 来检索第一个完成的任务。

如果您正在使用ExecutorCompletionService，请创建一个新实例来包装您的ExecutorService、submit 两个任务，然后调用take()。

例如：

public Future<String> submitPair(ExecutorService executorService) throws InterruptedException {
    ExecutorCompletionService<String> ecs = new ExecutorCompletionService<>(executorService);
    ecs.submit(() -> oneWay());
    ecs.submit(() -> orAnother());
    return ecs.take();
}

ExecutorCompletionService 不需要额外的清理。

Answer 2

使用CompletableFuture。

ExecutorService executorService = Executors.newFixedThreadPool(100);
CompletableFuture<?> one = CompletableFuture.supplyAsync(() -> oneWay(),  executorService);
CompletableFuture<?> two = CompletableFuture.supplyAsync(() -> orAnother(),  executorService);

return CompletableFuture.anyOf(one, two);