Limit czasu w oczekiwaniu na zakończenie partii kontraktów Futures?

Question

Mam zestaw Futures utworzony przez przesłanie Callable s do Executor. Pseudo kod:

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

Teraz chciałbym, aby wszystkie futures czekały najwyżej n sekund, aż wszystkie zostaną zakończone. Wiem, że mogę zadzwonić pod numer Future#get(timeout), ale jeśli zadzwonię do niego sekwencyjnie dla wszystkich moich przyszłości w pętli, zaczynają się dodawać timery. pseudokod:

for all futures 
    future.get(timeout) 

get bloki z timeout aż do wyniku jest gotowy. Dlatego też, jeśli pierwszy kończy się tuż przed przekroczeniem limitu czasu, a drugi kończy się tuż przed przekroczeniem limitu czasu, a więc cały czas wykonywania wynosi co najwyżej number of futures * timeout zamiast timeout.

Dlatego szukam metody, która akceptuje listę Future s i limit czasu, działa wszystko równolegle, a następnie zwraca kolekcję przyszłych wyników. Jakieś pomysły?

Answer 1

Można użyć ExecutorService.invokeAll:

Wykonuje podane zadania, zwracając listę Futures posiadających statusu i rezultatów, gdy wszystkie kompletne lub limit czasu upłynie, cokolwiek dzieje się w pierwszej kolejności. Future.isDone() jest prawdziwe dla każdego elementu zwróconej listy. Po powrocie zadania, które nie zostały zakończone, są anulowane. Zauważ, że ukończone zadanie mogło zostać zakończone normalnie lub przez zgłoszenie wyjątku. Wyniki tej metody są niezdefiniowane, jeśli dana kolekcja jest modyfikowana podczas tej operacji.

---

Jeśli masz już Future s, które trzeba monitorować i nie może korzystać invokeAll, można po prostu mierzyć timeout siebie. Pseudo-kod:

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

W ten sposób każda z przyszłych okresów będzie trwać co najwyżej do końca czasu oczekiwania.