Die Receiver-Goroutine blockiert nie, wenn Golang den Kanal schließt

Frageninhalt

Ich habe einen Code geschrieben, um den Go-Kanal zu lernen, einen Code wie unten gezeigt:

func main(){
    intChan := make(chan int, 1)
    strChan := make(chan string, 1)

    intChan <- 3
    strChan <- "hello"
    fmt.Println("send")

    // comment this, fatal error: all goroutines are asleep - deadlock!
    // close(intChan)
    // close(strChan)

    for {
        select {
        case e, ok := <-intChan:
            time.Sleep(time.Second * 2)
            fmt.Println("The case intChan ok: ", ok)
            fmt.Println("The case intChan is selected.", e)

        case e, ok := <-strChan:
            time.Sleep(time.Second)
            fmt.Println("The case strChan ok: ", ok)
            fmt.Println("The case strChan is selected.", e)
        }
    }
}

Wenn ich die close()-Funktion auskommentiere, wird die „for“-Anweisung blockiert, da der Fehler „Alle Goroutinen sind im Ruhezustand – Deadlock!“ lautet, was vernünftig erscheint.

Wenn ich den Kommentar entferne close(), hört die „für“-Anweisung nie auf. Der Empfänger erhält vom Kanal die Standardwerte 0 und Null und blockiert nie.

Auch wenn ich nichts an den Kanal sende und close() anrufe, nachdem ich den Kanal definiert habe. Der Empfänger wird niemals blockieren oder Fehler verursachen.

Ich bin verwirrt darüber, was die Funktion close macht. Startet sie eine Go-Routine, die einen bestimmten Standardwerttyp an den Kanal sendet und nie stoppt? close 函数的作用感到困惑，它是否启动一个 go 例程将特定类型的默认值发送到通道，并且永远不会停止？

正确答案

当频道关闭时，您仍然可以阅读它，但您的 ok 将为 false。所以，这就是为什么你的 for 永远不会停止。并且，您需要通过条件 if !ok {break } 来中断 for

Richtige Antwort

Wenn der Kanal geschlossen ist, können Sie ihn immer noch lesen, aber Ihr ok ist falsch. Deshalb hört Ihr for nie auf. Außerdem müssen Sie die for-Anweisung mit einem bedingten if !ok {break unterbrechen.

make(chan int, 1)Wenn der Kanal nicht geschlossen ist und Sie versuchen, Daten von ihm zu lesen, wird er blockiert oder nicht, abhängig vom gepufferten/ungepufferten Kanal.
make(chan int)Pufferkanal: Sie geben die Größe (

) an.

Ungepufferter Kanal: Sie haben keine Größe angegeben (close 的情况下，它将从您缓冲的通道读取数据一次，因为您通过 intchan <- 3 和 strchan <- "hello")

In deinem Kommentar

Sende Daten an den Kanal. Daher werden die folgenden von der Konsole gedruckten Ergebnisse angezeigt.

send
the case strchan ok:  true
the case strchan is selected. hello
the case intchan ok:  true
the case intchan is selected. 3

all goroutine are sleep - deadlockDanach liegen jedoch in beiden Pufferkanälen keine Daten mehr vor. Wenn Sie dann versuchen, es zu lesen, werden Sie blockiert, da im gepufferten Kanal keine Daten vorhanden sind. (Tatsächlich ist keine Pufferung auch dann der Fall, wenn keine Daten vorhanden sind.)

Dann erhalten Sie

, weil die Haupt-Goroutine blockiert ist und auf Daten vom Kanal wartet. Wenn Sie dieses Programm ausführen, wird übrigens eine Haupt-Goroutine gestartet, um Ihren Code auszuführen. Wenn nur eine Haupt-Goroutine blockiert ist, bedeutet das, dass Ihnen niemand beim Ausführen Ihres Codes helfen kann.

Sie können den folgenden Code vor der for-Anweisung hinzufügen. 🎜

go func() {
    fmt.Println("another goroutine")
    for {}
}()

🎜Sie werden feststellen, dass Sie nicht auf einen Deadlock stoßen, da es immer noch eine Goroutine gibt, die Ihren Code „könnte“ ausführen. 🎜

Das obige ist der detaillierte Inhalt vonDie Receiver-Goroutine blockiert nie, wenn Golang den Kanal schließt. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!