Timeout während des Wartens auf die Fertigstellung eines Stapels von Futures?

Question

Ich habe eine Reihe von Futures erstellt durch Übermittlung Callable s an eine Executor. Pseudo-Code:

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

Jetzt möchte ich alle Futures warten höchstens n Sekunden bis alles abgeschlossen. Ich weiß, ich kann Future#get(timeout) anrufen, aber wenn ich das sequenziell für alle meine Zukünfte in einer Schleife rufe, fangen die Zeitpunkte an, sich zu addieren. Pseudo-Code:

for all futures 
    future.get(timeout) 

get Blöcke mit einem Timeout, bis das Ergebnis ist fertig. Wenn daher der erste Vorgang kurz vor dem Timeout abgeschlossen wird und der zweite auch kurz vor dem Timeout abgeschlossen wird, ist die gesamte Ausführungszeit höchstens number of futures * timeout statt timeout.

Daher suche ich nach einer Methode, die eine Liste von Future s und ein Timeout akzeptiert, läuft alle parallel und gibt dann eine Sammlung von zukünftigen Ergebnissen. Irgendwelche Ideen?

Answer 1

können Sie ExecutorService.invokeAll verwenden:

Führt die gestellten Aufgaben, um eine Liste von Futures Rückkehr ihren Status und die Ergebnisse zu halten, wenn alle vollständigen oder das Timeout abläuft, je nachdem, was zuerst eintritt. Future.isDone() gilt für jedes Element der zurückgegebenen Liste. Bei der Rückkehr werden Aufgaben, die nicht abgeschlossen wurden, storniert. Beachten Sie, dass eine abgeschlossene Aufgabe normal oder durch Auslösen einer Ausnahme beendet werden konnte. Die Ergebnisse dieser Methode sind nicht definiert, wenn die angegebene Sammlung geändert wird, während diese Operation ausgeführt wird.

---

Wenn Sie bereits Future s haben, die Sie überwachen müssen und können invokeAll nicht verwenden, können Sie einfach das Timeout selbst messen. Pseudocode:

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

Auf diese Weise geben Sie jeder Zukunft höchstens die Dauer, die bis zum Erreichen der Zeitüberschreitung übrig ist.