Einführung in die Parallelität in der Go-Sprache (mit Code)

Auf die Frage, warum wir Go-Sprache verwenden, müssen wir die gleichzeitige Programmierung der Go-Sprache erwähnen. Das Schreiben sehr langwieriger und komplexer gleichzeitiger Programme in der Sprache C scheint in der Sprache Go immer sehr praktisch zu sein.

Gleichzeitige Programme in Go basieren auf zwei Dingen: Goroutine und Kanal

Verstehen Sie, was Goroutine ist?

Für Anfänger und Gelehrte Goroutine kann direkt als Thread verstanden werden. Wenn Sie go für eine Funktion aufrufen und eine Goroutine starten, entspricht dies dem Starten eines Threads zum Ausführen der Funktion.

Eigentlich ist eine Goroutine nicht gleichbedeutend mit einem Thread. Die Entstehung von Goroutine besteht darin, das ursprüngliche Thread-Konzept zu ersetzen und die kleinste Planungseinheit zu werden.

Sobald eine Goroutine ausgeführt wird, wird zuerst der Thread durchsucht. Wenn der Thread blockiert ist, wird er einem inaktiven Thread zugewiesen. Beachten Sie, dass der Thread nach Abschluss der Goroutine-Ausführung nicht recycelt und herausgeschoben wird, sondern zu einem Leerlauf-Thread wird.

Die Verwendung von Goroutine

ist sehr einfach zu verwenden, fügen Sie einfach ein go

f(11)

hinzu vor der Funktion

go f(11) //Dies dient dazu, die Funktion f() als Goroutine laufen zu lassen

Aber was soll ich tun, wenn der Hauptthread warten muss? damit eine Goroutine vor der Verarbeitung fertig ist? Nehmen Sie ein Beispiel aus „Learning Go Language“.

Was bedeutet hier Zeile 18 schlafen? Dies dient dazu, darauf zu warten, dass die beiden oben genannten Go-Ready-Prozesse abgeschlossen sind.

Okay, hier kommt eine Anforderung: Nachdem eine Goroutine beendet wurde, muss sie Daten an den Hauptthread übertragen, um dem Hauptthread mitzuteilen, dass die Goroutine beendet wurde.

Das Konzept des Kanals wird hier vorgestellt

Die Verwendung von Kanal

Die Bedeutung von Kanal kann im Volksmund verstanden werden so: Main Der Thread sagt allen, dass man eine Goroutine öffnen kann, aber ich habe eine Pipe in meinem Hauptthread geöffnet. Nachdem Sie fertig sind, was Sie tun möchten, stopfen Sie etwas in die Pipe, um mir mitzuteilen, dass Sie es abgeschlossen haben.

Das obige Beispiel kann wie folgt geändert werden:

Einige Informationen aus diesem Programm:

Nur ​​1 Kanal Das ist möglich Verwenden Sie make, um

Das Grundformat ist c := make(chan int)

int gibt an, welche Art von Daten diese Pipe übertragen kann

2 Der Vorgang des Einfügens von Daten in den Kanal

c

Ist das nicht sehr anschaulich?

3 Ausgabe von Daten aus dem Kanal

4 Warum muss es zweimal ausgegeben werden (Zeilen 4 und 5?)

Weil 2 und 3 werden gestartet Zwei Goroutinen, jede Goroutine gibt eine 1 an die Pipe aus, daher muss der Hauptthread diese zweimal empfangen, um anzuzeigen, dass beide Goroutinen beendet wurden

Weiteres Verständnis des Kanals:

Der Kanal ist in zwei Typen unterteilt: einen mit Puffer und einen ohne Puffer. Der Standardwert ist ohne Puffer

ci := make(chan int) //Kein Puffer

cj := make(chan int, 0) //Kein Puffer

cs := make(chan int, 100) //Mit Puffer

Mit Pufferkanal, also Achten Sie auf „put“ vor „get“

Ungepufferter Kanal, achten Sie also auf „get“ vor „put“

Geben Sie auch Hallo Welt zuerst aus, verwenden Sie den gepufferten Kanal und den ungepufferten Kanal sind wie folgt:

Gepufferter Kanal:

var a string
var c = make(chan int, 10)
  
func f() {
    a = "hello, world"
    c <- 0
}
  
func main() {
    go f()
    <-c
    print(a)
 
}

Hier gibt es einen Puffer, daher geht der Vorgang des Einfügens von Daten c

Ungepufferter Kanal:

var a string
var c = make(chan int)
  
func f() {
    a = "hello, world"
    <-c
}
  
func main() {
    go f()
    c <- 0
    print(a)
 
}

Da c ein ungepufferter Kanal ist, muss die Abrufoperation garantiert sein voraus Empfohlen:

Golang-TutorialSpalte

Das obige ist der detaillierte Inhalt vonEinführung in die Parallelität in der Go-Sprache (mit Code). Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!