Heim  >  Artikel  >  Backend-Entwicklung  >  Aufruf von defer in einer for-Schleife – gibt es eine bessere Möglichkeit, das Lesen der Antwort vom Kanal zu verzögern?

Aufruf von defer in einer for-Schleife – gibt es eine bessere Möglichkeit, das Lesen der Antwort vom Kanal zu verzögern?

王林
王林nach vorne
2024-02-09 12:15:221166Durchsuche

在 for 循环中调用 defer - 是否有更好的方法来延迟从通道读取响应?

Aufrufverzögerung in einer for-Schleife – gibt es eine bessere Möglichkeit, das Lesen der Antwort vom Kanal zu verzögern? Dies ist ein häufiges Problem, auf das viele Entwickler bei der Verwendung der Go-Sprache stoßen. Das Schlüsselwort „defer“ wird verwendet, um die Ausführung von Funktionen in der Go-Sprache zu verzögern. Durch die Verwendung von „defer“ in einer for-Schleife kann sichergestellt werden, dass bestimmte Operationen nach dem Ende jeder Schleife ausgeführt werden. Wenn Sie jedoch die Antwort des Kanals in jeder Schleife lesen müssen, ist die Verwendung von defer möglicherweise nicht die beste Wahl. Gibt es also eine bessere Möglichkeit, das Lesen der Antwort vom Kanal zu verzögern? Lassen Sie es uns gemeinsam erkunden.

Frageninhalt

Ich versuche eine Funktion aufzurufen, die einen Kanal in einer Schleife zurückgibt. Hängen Sie dann diesen Kanal an das Slice an channelslice. Abschließend iterieren Sie über die Kanalabschnitte und drucken die Antwort für jeden Kanal aus. Wenn ich das mache, zeigt meine IDE die Warnung:

possible resource leak, 'defer' is called in the 'for' loop

Wie Sie sehen können, rufe ich close(channelslice[i]) innerhalb der zweiten for-Schleife auf. Ist das nicht zu empfehlen? Wie könnte dies außerdem zu einem Ressourcenleck führen? Gibt es eine bessere Möglichkeit, mit dem Schließen oder Schneiden von Kanälen umzugehen?

package main


import (
    "fmt"
    "math/rand"
)

func t() chan int {
    c := make(chan int)
    go func() {
        c <- rand.Intn(100)
    }()

    return c
}

func main() {
    channelSlice := make([]chan int, 0)
    for i := 0; i<100; i++ {
        // Keep making concurrent calls
        // Will read responses from the channel later
        channelSlice = append(channelSlice, t())
    }

    for i := 0; i<100; i++ {
        defer close(channelSlice[i]) // Warning thrown by IDE
        fmt.Println(<-channelSlice[i])
    }
}

Workaround

Wie @mkopriva betont hat,

Verzögerte Aufrufe werden ausgeführt, wenn umgebende Funktionen beendet werden, sie werden nicht aufgerufen, wenn umgebende nichtfunktionale Blöcke beendet werden. Kapseln Sie den Schlaufenkörper in einem Verschluss ein.

Das habe ich getan:

for i := 0; i<100; i++ {
        func() {
            defer close(channelSlice[i])
            fmt.Println(<-channelSlice[i])
        }()
    }

Wie Sie sehen können, habe ich die defer-Anweisung in ein iife (sofort aufgerufenen Funktionsausdruck) eingeschlossen. Es wäre auch schön, es zu einem Abschluss zu machen.

Dadurch wird sichergestellt, dass der Kanal jetzt geschlossen wird und kein Speicherverlust auftritt.

Das obige ist der detaillierte Inhalt vonAufruf von defer in einer for-Schleife – gibt es eine bessere Möglichkeit, das Lesen der Antwort vom Kanal zu verzögern?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!

Stellungnahme:
Dieser Artikel ist reproduziert unter:stackoverflow.com. Bei Verstößen wenden Sie sich bitte an admin@php.cn löschen