Wie kann CompletionService verwendet werden, um das Warten auf eine Liste von Futures zu optimieren und Ausnahmen effizient zu behandeln?

Optimieren der Wartezeit auf zukünftige Listen mit CompletionService

Bei der Arbeit mit einer Liste von Futures ist es wichtig, effizient auf deren Abschluss zu warten oder Ausnahmen zu behandeln Vermeiden Sie unnötige Verzögerungen.

Angenommen, Sie haben die folgende Methode, die eine Liste von Futures zurückgibt:

List<Future<O>> futures = getFutures();

Um auf den Abschluss zu warten oder Ausnahmen abzufangen, könnte ein naiver Ansatz sein:

wait() {
  for(Future f : futures) {
    try {
      f.get();
    } catch(Exception e) {
       //Specific exception handling
       //Exception in a future, stop waiting
       return;
    }
  }
}

Dieser Ansatz wartet jedoch auf jede Zukunft, unabhängig von Ausnahmen in früheren Futures.

Eine Lösung besteht darin, einen CompletionService einzusetzen, um Futures zu erhalten, sobald sie verfügbar sind. Wenn eine Ausnahme auftritt, können Sie andere Aufgaben abbrechen:

Executor executor = Executors.newFixedThreadPool(4);
CompletionService<SomeResult> completionService = new ExecutorCompletionService<SomeResult>(executor);

//Submit tasks
for(int i = 0; i < 4; i++) {
  completionService.submit(() -> {
    ...
    return result;
  });
}

int received = 0;
boolean errors = false;

while(received < 4 && !errors) {
  Future<SomeResult> resultFuture = completionService.take(); //Blocks if none available
  try {
    SomeResult result = resultFuture.get();
    received++;
    ... //Process result
  } catch(Exception e) {
    //Log and set error flag
    errors = true;
  }
}

Bei diesem Ansatz werden Aufgaben an den Ausführenden übermittelt und abgeschlossene Aufgaben werden über den Abschlussdienst empfangen. Wenn in einer empfangenen Aufgabe eine Ausnahme auftritt, wird die while-Schleife beendet und Sie können alle verbleibenden Aufgaben mit der Methode „shutdownNow()“ des Executors abbrechen.

Das obige ist der detaillierte Inhalt vonWie kann CompletionService verwendet werden, um das Warten auf eine Liste von Futures zu optimieren und Ausnahmen effizient zu behandeln?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!