Wie kann ich vervollständige Future verwenden, um die Reihenfolge der Stapelschnittstellenanforderungen zu gewährleisten und die Ergebnisse effizient zu verarbeiten?

Java gleichzeitige Programmierung: Verwenden Sie die Anforderungen an die Batch -Schnittstelle mit Vervollständigungsfunktion zur effizienten und ordnungsgemäßen Handlungsbatch -Schnittstelle

Ein hoher gleichzeitiger Zugriff auf Schnittstellen von Drittanbietern kann die Datenverarbeitungseffizienz erheblich verbessern. Wenn jedoch die Thread-Ausführungsreihenfolge nicht gesteuert wird, stimmt das Endergebnis möglicherweise nicht mit der ursprünglichen Datenreihenfolge überein, was zu nachfolgenden Verarbeitungsfehlern führt. In diesem Artikel wird vorgestellt, wie die Vervollständigung von Java verwendet werden kann, um die ordnungsgemäße Verarbeitung von Schnittstellenanforderungen zu gewährleisten, und führt zu einer Umgebung mit mehreren Threads.

Problem: Verwenden Sie CompletableFuture.runAsync direkt, um asynchrone Anrufe zu tätigen. Aufgrund der unvorhersehbaren Reihenfolge der Thread -Ausführung steht das zurückgegebene Ergebnis nicht mit der Reihenfolge der ursprünglichen Datenliste nicht. CompletableFuture.allOf kann nur die Fertigstellung aller Aufgaben garantieren, und die Bestellung kann nicht garantiert werden.

Lösung: Verwenden Sie CompletableFuture.supplyAsync , was das Ergebnis zurückgibt. Speichern Sie das Rückgabeergebnis jeder asynchronen Aufgabe in CompletableFuture<string></string> In der Liste werden nach Abschluss aller Aufgaben die Ergebnisse in der ursprünglichen Reihenfolge über stream().map(CompletableFuture::join).collect(Collectors.toList()) .

Verbessertes Codebeispiel:

 public static void main (String [] args) {
    Liste<string> Datalist = new ArrayList  (); // Originaldatenliste // ... Datalist initialisieren ...

    ExecutorService Executorservice = New ThreadPoolexecutor (
            10, // corepoolsize
            20, // maximumpoolsize
            60l, // keepalivetime
            Zeitlich.sekunden,
            Neues LinkedBlockingQueue  (1024), // WorkQueue
            neuer threadpoolexecutor.calrrunspolicy () // Handler
    );

    Liste <completablefuture> > futures = new ArrayList  ();
    für (String -Daten: Datalist) {
        futures.add (komplettableFuture.supplyasync (() -> {
            logger.info ("Verarbeitungsdaten: {}", Daten);
            // Rufen Sie die Schnittstelle von Drittanbietern auf, um Daten zu verarbeiten
            // ... Schnittstellenanruf- und Ergebnisverarbeitungslogik ...
            Rückgabedaten " - verarbeitetes Ergebnis"; // Rückgabeverarbeitungsergebnis}, ExecutorService));
    }

    CompleteableFuture.Allof (Futures.toArray (neue Vervollständigungsfuture [0])). Thenrun (() -> {
        Liste<string> Ergebnisse = Futures.stream ()
                .MAP (Vervollständigbare Future :: Join)
                .Collect (sammel.tolist ());
        logger.info ("Alle Aufgaben erledigt. Ergebnisse: {}", json.tojonstring (Ergebnisse));
        // nachfolgende Verarbeitungsergebnisse}). Thenrun (() -> ExecutorService.shutdown ());
}</string></completablefuture></string>

Der verbesserte Code verwendet CompletableFuture.supplyAsync , um die Ergebnisse jedes Schnittstellenaufrufs zurückzugeben, und wird in der futures -Liste gespeichert. CompletableFuture.allOf stellt sicher, dass die Ergebnisse nach Abschluss aller Aufgaben verarbeitet werden. stream().map(CompletableFuture::join).collect(Collectors.toList()) stellt sicher, dass die Ergebnisse in der ursprünglichen Reihenfolge gesammelt werden, wodurch das Problem der Parallelität in der Reihenfolge der Ergebnisse gelöst wird. Der Code verwendet auch einen benutzerdefinierten Thread -Pool, um eine bessere Kontrolle über die Ressourcenverwendung zu erhalten.

Das obige ist der detaillierte Inhalt vonWie kann ich vervollständige Future verwenden, um die Reihenfolge der Stapelschnittstellenanforderungen zu gewährleisten und die Ergebnisse effizient zu verarbeiten?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!