Heim  >  Artikel  >  Backend-Entwicklung  >  Golang stellt fest, dass Chan geschlossen ist

Golang stellt fest, dass Chan geschlossen ist

WBOY
WBOYOriginal
2023-05-10 15:55:072147Durchsuche

Beim Erlernen und Verwenden von Golang stoßen wir häufig auf Situationen, in denen wir Chan verwenden müssen, um die Coroutine-Parallelität zu implementieren. Bei der tatsächlichen Verwendung müssen wir jedoch manchmal feststellen, ob ein Kanal geschlossen wurde. In diesem Artikel werden verschiedene Golang-Methoden vorgestellt, um festzustellen, ob ein Kanal geschlossen ist.

Zunächst ist es sehr wichtig, die grundlegende Verwendung und die Eigenschaften von Chan in Golang zu verstehen. Chan in Golang ist ein auf dem CSP-Modell basierender Parallelitätskontrollmechanismus, der die Kommunikation und Synchronisation zwischen Coroutinen realisieren kann. Die Kommunikationsmethode von Chan ist blockierend. Wenn der Lese- oder Schreibvorgang nicht abgeschlossen werden kann, wird die Coroutine blockiert, bis Daten gelesen oder freier Speicherplatz geschrieben werden kann. Ein Merkmal von Chan ist, dass nach dem Schließen von Chan erneute Lese- und Schreibvorgänge zu Panik führen. Daher ist es sehr wichtig, festzustellen, ob Chan geschlossen wurde.

Es gibt mehrere Möglichkeiten, um festzustellen, ob Chan in Golang geschlossen ist:

Methode 1: Fügen Sie ein Signal hinzu.

Wir können feststellen, ob Chan geschlossen ist, indem wir der Chan-Variablen ein Signal hinzufügen. Wenn der Kanal geschlossen ist, können wir anderen Coroutinen mitteilen, dass der Kanal geschlossen wurde, indem wir das Signal schließen.

Der Beispielcode lautet wie folgt:

package main

import "fmt"

func main() {
    a := make(chan int)
    quit := make(chan bool)

    go func() {
        for {
            select {
            case x := <-a:
                fmt.Println(x)
            case <-quit:
                fmt.Println("chan closed")
                return
            }
        }
    }()

    for i := 0; i < 5; i++ {
        a <- i
    }
    close(a)
    quit <- true

    fmt.Println("done")
}

Im obigen Code erstellen wir einen Chan vom Typ int mit dem Namen a und einen Chan vom Typ bool mit dem Namen quit. In der Coroutine überwacht select den Lesevorgang von a und den Signalschließvorgang von quit. Wenn Chan geschlossen wird, wird die Coroutine durch das Quit-Signal informiert. In der Haupt-Coroutine geben wir 5 Daten in a ein, schließen dann a über die Funktion close() und benachrichtigen das Ende der Coroutine über das Quit-Signal. Abschließend wird „Done“ gedruckt, um anzuzeigen, dass die Programmausführung abgeschlossen ist.

Methode 2: Verwenden Sie die Bereichsfunktion

Wir können die Bereichsfunktion auch verwenden, um festzustellen, ob der Kanal geschlossen wurde. Wenn Kanal geschlossen wird, endet die Bereichsfunktion. Hier ist der Beispielcode:

package main

import "fmt"

func main() {
    a := make(chan int)

    go func() {
        for x := range a {
            fmt.Println(x)
        }
        fmt.Println("chan closed")
    }()

    for i := 0; i < 5; i++ {
        a <- i
    }
    close(a)

    fmt.Println("done")
}

Im obigen Code erstellen wir zunächst einen Chan vom Typ int mit dem Namen a. In der Coroutine durchlaufen die Daten in Chan die Range-Funktion. Wenn Chan geschlossen ist, beendet die Range-Funktion die Coroutine und gibt „chan geschlossen“ aus, um anzuzeigen, dass Chan geschlossen wurde. In der Hauptkoroutine geben wir 5 Daten in a ein und schließen a dann über die Funktion close(). Abschließend wird „Done“ gedruckt, um anzuzeigen, dass die Programmausführung abgeschlossen ist.

Methode 3: Verwenden Sie die ok-Variable

Eine andere Möglichkeit, festzustellen, ob Chan geschlossen wurde, ist die Verwendung der ok-Variablen. Wenn der Kanal geschlossen ist, wird die Variable ok zu false.

Der Beispielcode lautet wie folgt:

package main

import "fmt"

func main() {
    a := make(chan int)

    go func() {
        for {
            x, ok := <-a
            if !ok {
                fmt.Println("chan closed")
                break
            }
            fmt.Println(x)
        }
    }()

    for i := 0; i < 5; i++ {
        a <- i
    }
    close(a)

    fmt.Println("done")
}

Im obigen Code erstellen wir einen Chan vom Typ int mit dem Namen a. In der Coroutine durchlaufen wir die Daten in chan durch eine for-Schleife. Wenn die ok-Variable „false“ wird, bedeutet dies, dass chan geschlossen wurde und die Schleife endet. In der Hauptkoroutine geben wir 5 Daten in a ein und schließen dann a über die Funktion close(). Abschließend wird „Done“ gedruckt, um anzuzeigen, dass die Programmausführung abgeschlossen ist.

Die oben genannten drei Methoden können alle bestimmen, ob Chan in Golang geschlossen ist. Sie können die geeignete Methode entsprechend Ihren persönlichen Bedürfnissen auswählen. Die Feststellung, ob Chan geschlossen ist, ist ein wichtiger Wissenspunkt, der in Golang verwendet wird. Ich hoffe, dass er für das Lernen aller hilfreich sein wird.

Das obige ist der detaillierte Inhalt vonGolang stellt fest, dass Chan geschlossen ist. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!

Stellungnahme:
Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn