Wie kann man effizient auf eine Liste von Futures warten und Ausnahmen behandeln?

Effizientes Warten auf einer Liste von Futures

Beim Umgang mit einer Liste von Futures besteht das Ziel darin, bis zur Fertigstellung oder dem Eintreten von zu warten in Zukunft eine Ausnahme sein. Ein naiver Ansatz mit einzelnen Aufrufen von f.get() kann zu unnötigem Warten führen, wenn eine Ausnahme früh auftritt.

Unnötiges Warten mit CompletionService vermeiden

Um dieses Problem zu beheben Bei diesem Problem kommt die CompletionService-Klasse ins Spiel. Es ermöglicht die Ausführung asynchroner Aufgaben und den Thread-sicheren Abruf ihrer Ergebnisse, sobald sie verfügbar sind. So verwenden Sie es:

<code class="java">Executor executor = Executors.newFixedThreadPool(4);
CompletionService<someresult> completionService = new ExecutorCompletionService(executor);

// Submit tasks to the service
for (int i = 0; i () {
        @Override
        public SomeResult call() {
            // Task logic here
            return result;
        }
    });
}

int received = 0;
boolean errors = false;

// Loop until all tasks are complete or an error occurs
while (received  resultFuture = completionService.take(); // Blocks if nothing available
    try {
        SomeResult result = resultFuture.get();
        received++;
        // Process result here
    } catch (Exception e) {
        // Log error
        errors = true;
    }
}

// Consider canceling remaining tasks if an error occurred</someresult></code>

Durch die Verwendung des CompletionService-Ansatzes können Sie die Erledigung von Aufgaben in Echtzeit überwachen und die weitere Verarbeitung stoppen, wenn ein Fehler auftritt, wodurch unnötige Wartezeiten vermieden werden.

Das obige ist der detaillierte Inhalt vonWie kann man effizient auf eine Liste von Futures warten und Ausnahmen behandeln?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!