Heim >Java >javaLernprogramm >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 < 4; i++) { completionService.submit(new Callable<SomeResult>() { @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 < 4 && !errors) { Future<SomeResult> 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</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!