Wie verwendete ich CompletenableFuture, um die Bestellkonsistenz der Ergebnissen der Stapelschnittstelle zu gewährleisten?

Effizient gleichzeitige Verarbeitung von Stapelschnittstellenanforderungen: Stellen Sie sicher, dass die Reihenfolge der Ergebnisse konsistent ist

Gleichzeitige Aufrufe mehrerer Schnittstellen von Drittanbietern können die Effizienz bei der effizienten Bearbeitung großer Datenmengen erheblich verbessern. Eine einfache Multithread -Parallelität kann jedoch dazu führen, dass die Reihenfolge der Rückgabeergebnisse inkonsistent ist und der ursprünglichen Datenliste nicht entspricht. In diesem Artikel wird vorgestellt, wie dieses Problem mithilfe von Java CompletableFuture gelöst werden kann, um sicherzustellen, dass die Interface -Aufrufergebnisse genau der ursprünglichen Datenreihenfolge übereinstimmen.

Frage:

Nehmen wir an, dass mehr als 1000 Schnittstellen von Drittanbietern gleichzeitig aufgerufen werden müssen, um die Ergebnisse zurückzugeben. Wenn mehrere Threads mit einer einfachen for begonnen werden, kann die Reihenfolge der Schnittstellenaufrufe nicht garantiert werden und die Reihenfolge der Endergebnisse stimmt nicht mit der ursprünglichen Datenliste überein. Ein Beispielcode verwendet CompletableFuture.runAsync , um asynchrone Aufgaben auszuführen, ignoriert jedoch die Erfassung von Ergebnissen und die Aufrechterhaltung der Sequenzialität.

Lösung:

Um sicherzustellen, dass die Reihenfolge der Ergebnisse mit der Originaldatenliste übereinstimmt, besteht der Schlüssel darin, CompletableFuture.supplyAsync anstelle von CompletableFuture.runAsync zu verwenden. supplyAsync -Methode kann ein Ergebnis zurückgeben, während runAsync keinen Wert zurückgibt. Geben Sie die Ergebnisse jeder Schnittstellenaufruf über supplyAsync zurück und sammeln Sie die Ergebnisse in die Liste, indem Sie die Verarbeitung streamen, um sicherzustellen, dass die Reihenfolge der Ergebnisse mit der ursprünglichen Datenliste übereinstimmt.

Verbesserter Code:

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

    ExecutorService Executorservice = New ThreadPoolexecutor (
            // Die Anzahl der Kern -Threads runchtime.getRuntime (). AFFORMPROCESSORS (),
            // Maximale Anzahl von Threads runTime.getRuntime (). AFFORMPROCESSORS () * 2,
            // Überlebenszeit von Thread 60L, TimeUnit.seconds,
            Neues LinkedBlockingQueue  (),
            neuer threadpoolexecutor.calrrunspolicy ());

    Liste <completablefuture> > futures = new ArrayList  ();
    für (String -Daten: Datalist) {
        futures.add (komplettableFuture.supplyasync (() -> {
            logger.info ("Ausführung von asynchronem Thread starten->>" Daten);
            // Rufen Sie die Schnittstelle an und geben Sie Daten über
            // beurteilen Sie, ob Daten übereinstimmen, basierend auf dem Schnittstellenrückgabewert // Rückgabe des verarbeiteten Ergebnisrücklaufprozessdata (Daten); // Daten verarbeiten und das Ergebnis zurückgeben}, ExecutorService)); // Verwenden Sie einen benutzerdefinierten Threadpool}

    // Nach der Verarbeitung der Logik aller Anfragen abgeschlossen, komplettsableFuture.Allof (futures.toArray (neuer Vervollständigungsfuture [0])). Thenrun (() -> {
        Liste<string> Ergebnisse = Futures.stream ()
                .MAP (Vervollständigbare Future :: Join)
                .Collect (sammel.tolist ());
        logger.info ("Thread -Ausführung ist abgeschlossen: {}", json.tojonstring (Ergebnisse));
        // rufen Sie an, um SMS}). Thenrun (() -> ExecutorService.shutdown ());
}

// Methode zur Verarbeitung von Daten, ändern Sie private statische String processData (String -Daten) {{
    // ... Schnittstellenanruf- und Datenverarbeitungslogik ...
    Daten zurückgeben "verarbeitetes Ergebnis";
}</string></completablefuture></string>

Durch das Speichern der Ergebnisse jeder CompletableFuture in der futures -Liste und das Sammeln der Ergebnisse am Ende unter Verwendung von futures.stream().map(CompletableFuture::join).collect(Collectors.toList()) ist die Ergebnisreihenfolge in Übereinstimmung mit der ursprünglichen Datenliste überein. CompletableFuture::join -Methode blockiert, bis das Ergebnis CompletableFuture erzielt wird. Dies löst effektiv das Problem inkonsistenter Ergebnisse im ursprünglichen Code.

Das obige ist der detaillierte Inhalt vonWie verwendete ich CompletenableFuture, um die Bestellkonsistenz der Ergebnissen der Stapelschnittstelle zu gewährleisten?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!