forEach vs. for: Der asynchrone Showdown!

Verstehen, wie sich Schleifenauswahlmöglichkeiten auf die asynchrone Leistung auswirken

In meinem letzten Projekt musste ich eine große Anzahl von Datensätzen in einer NoSQL-Datenbank aktualisieren – über tausend. Da es nicht möglich war, sie alle auf einmal zu aktualisieren, und der Prozess außerdem asynchron war, habe ich beschlossen, sie in kleineren Stapeln von jeweils 20 Datensätzen zu verarbeiten. Ich habe dies in einer Schleife mit forEach implementiert, wobei jeder Satz von 20 aktualisiert wurde, bevor mit dem nächsten Satz fortgefahren wurde. Nachdem ich diesen Ansatz jedoch in die Praxis umgesetzt hatte, stellte ich fest, dass nicht alle Datensätze wie erwartet aktualisiert wurden, selbst bei diesen kleineren Stapeln. Als ich beispielsweise versuchte, einen Stapel von 25 Datensätzen zu aktualisieren, wurden nur 10 erfolgreich aktualisiert. Für die anderen 10 Datensätze gab es keine Protokolle und die Anzahl der Datensätze, die nicht aktualisiert werden konnten, schwankte zufällig – manchmal 12, manchmal 5 oder manchmal 7.

Beim weiteren Debuggen habe ich festgestellt, dass diese Datensätze wahrscheinlich während des Aktualisierungsvorgangs übersprungen werden. Warum ist das nun passiert? Lassen Sie uns dieses Problem untersuchen, um das Verhalten zu verstehen und mögliche Gründe dafür zu identifizieren.

Problem
Nach einigen Recherchen habe ich herausgefunden, dass die Verwendung einer asynchronen Funktion innerhalb einer forEach-Schleife ohne einen geeigneten Mechanismus zum Warten auf alle Iterationen zu Problemen führen kann. In diesem Fall haben wir async/await innerhalb der forEach-Schleife verwendet, ohne sicherzustellen, dass alle Iterationen abgewartet wurden (siehe Code unten):

async function patchRecords(records) {
    // Here, the length of records is 25
    let successfulUpdates = 0; // Initialize a counter for successful updates

    records.forEach(async (item) => {
        await databaseName.patch(item);
        successfulUpdates++; // Increment counter on successful update
    });
    // Return the number of records updated successfully
    return successfulUpdates;
}

const response = await patchRecords(records); // Make sure to await this call

Im obigen Code gibt es keinen Mechanismus, der sicherstellt, dass alle asynchronen Iterationen der Schleife abgeschlossen werden. Die forEach-Methode löst mehrere asynchrone Aufrufes aus, um die Datensätze zu patchen, aber die patchRecords-Funktion erreicht schnell die Return-Anweisung, ohne auf den Abschluss dieser Patches zu warten. Während die Aktualisierungen im Hintergrund verarbeitet werden, läuft die Funktion daher weiter, ohne auf deren Abschluss zu warten. Dies kann dazu führen, dass einige ausstehende Versprechen nicht eingehalten werden, was dazu führen kann, dass Updates übersprungen oder verworfen werden.

Lösung
Wie können wir das also lösen? Bevor wir uns mit der Lösung befassen, wollen wir zunächst die verschiedenen Möglichkeiten zur Iteration über Daten verstehen. Grundsätzlich gibt es zwei Ansätze: Iterieren über Daten sequentiell oder parallel.

Wenn Sie asynchron und sequentiell über Daten iterieren möchten, kann die Verwendung einer forEach-Schleife zu den von uns besprochenen Problemen führen. Stattdessen ist es besser, eine moderne for…of-Schleife oder eine einfache for-Schleife zu verwenden, da diese eine ordnungsgemäße Funktion von await ermöglichen und sicherstellen, dass alle Aktualisierungen verarbeitet werden ohne übersprungen zu werden (siehe Code unten).

async function patchRecords(records) {
    // Here, the length of records is 25
    let successfulUpdates = 0; // Initialize a counter for successful updates

    records.forEach(async (item) => {
        await databaseName.patch(item);
        successfulUpdates++; // Increment counter on successful update
    });
    // Return the number of records updated successfully
    return successfulUpdates;
}

const response = await patchRecords(records); // Make sure to await this call

Wenn Sie andererseits Datensätze parallel verarbeiten möchten, funktioniert die Verwendung von forEach wiederum nicht. Während jeder asynchrone Rückruf ein Versprechen zurückgibt, bleiben einige dieser Versprechen möglicherweise unerfüllt, weil nicht auf sie gewartet wird. Verwenden Sie stattdessen map, um eine Reihe von Versprechen zu generieren, und warten Sie diese dann mit Promise.all ab (siehe Code unten).

async function patchRecords(records) {
    let successfulUpdates = 0; // Counter for successful updates

    for (const item of records) {
        try {
            // Query to patch each record
            await databaseName.patch(item);
            successfulUpdates++; // Increment counter on success
        } catch {
            // Handle any errors
        }
    }

    return successfulUpdates; // Return the number of records updated successfully
}

const response = await patchRecords(records); // Make sure to await this call

Dies zeigt, wie sich die Wahl der richtigen Schleifenmethode stark auf die erwarteten Ergebnisse Ihrer asynchronen Vorgänge auswirken kann. Die Art der Schleife, die Sie verwenden – ob forEach, for…of oder eine Standard-for-Schleife – spielt eine entscheidende Rolle dabei, wie gut Ihr Code asynchrone Aufgaben verwaltet.

Zusammenfassung

• Herausforderung: Das Massenaktualisieren von Datensätzen mit forEach führte zu inkonsistenten Aktualisierungen, wobei viele Datensätze übersprungen wurden.
• Grundursache: forEach wartet nicht auf den Abschluss asynchroner Vorgänge, was zu unerfüllten Versprechen führt.
• Lösung: Verwenden Sie eine for…of-Schleife, um der Reihe nach auf jede Datensatzaktualisierung zu warten, um die Genauigkeit zu gewährleisten, oder verwenden Sie Map mit Promise.all für gleichzeitige Aktualisierungen.

Habe ich die Dinge klar erklärt? Lass es mich unten in den Kommentaren wissen.

Es hat mir Spaß gemacht, meine Erfahrungen zu teilen, und ich hoffe, dass Sie sie auch wertvoll fanden! Da ich diesen Bereich noch erforsche, würde ich mich über Ihr Feedback und Ihre Vorschläge freuen. ☺️ Wenn Sie Bereiche sehen, in denen ich mich verbessern kann, oder Themen haben, die ich behandeln soll, zögern Sie bitte nicht, mich zu kontaktieren! ? Webseite. Ich freue mich darauf, mit Ihrer Hilfe zu lernen und zu wachsen. ??

Das obige ist der detaillierte Inhalt vonforEach vs. for: Der asynchrone Showdown!. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!