Тайм-аут в ожидании завершения партии фьючерсов?

Question

У меня есть набор Futures, созданный путем отправки Callable s на номер Executor. Псевдокод:

for all tasks 
    futures.add(executor.submit(new callable(task))) 

Теперь я хотел бы получить все фьючерсы, ожидающие не более n секунд, пока все не закончится. Я знаю, что могу позвонить Future#get(timeout), но если я назову это последовательно для всех своих фьючерсов в цикле, таймауты начнут складываться. Псевдо код:

for all futures 
    future.get(timeout) 

get блоки с тайм-аут, пока результат будет готов. Поэтому, если первое завершено непосредственно перед таймаутом, а второе также завершается непосредственно перед таймаутом, и так все время выполнения составляет number of futures * timeout максимум, а не timeout.

Следовательно, я ищу метод, который принимает список Future s и тайм-аут, выполняет все параллельно и затем возвращает коллекцию будущих результатов. Есть идеи?

Answer 1

Вы можете использовать ExecutorService.invokeAll:

Выполнение поставленных задач, возвращая список фьючерсов, имеющих свой статус и результаты, когда все полные или тайм-аут истекает, в зависимости от того произойдет первым. Future.isDone() верно для каждого элемента возвращаемого списка. По возвращении задачи, которые не были выполнены, отменены. Обратите внимание, что завершенная задача может завершиться либо нормально, либо путем исключения исключения. Результаты этого метода не определены, если данный сборник изменен во время выполнения этой операции.

---

Если у вас уже есть Future сек, что вам нужно контролировать и не могут использовать invokeAll, вы можете просто измерить тайм-аут себя. Псевдо код:

long endTime = System.currentTimeMillis() + timeoutMS; 
for(f : futures) 
    f.get(Math.max(0, endTime - System.currentTimeMillis()), TimeUnit.MILLISECONDS); 

Таким образом, вы даете каждому будущее самое длительность, что осталось, пока не достигнете тайм-аут.