Golang Concurrency Programming Guide: Erkundung der Geheimnisse der Parallelverarbeitung

Die gleichzeitige Programmierung in Go verwendet leichtgewichtige Threads (Goroutine) und Kommunikationsmechanismen (Pipelines), um eine parallele Aufgabenausführung zu implementieren. Synchronisierungsprimitive (z. B. Mutexe) werden verwendet, um den Zugriff zwischen Goroutinen zu koordinieren. Zu den praktischen Beispielen gehört die Erstellung effizienter gleichzeitiger Webdienste zur Bearbeitung mehrerer Anfragen.

Leitfaden zur gleichzeitigen Programmierung in Go: Erkundung der Geheimnisse der Parallelverarbeitung

Einführung

Die gleichzeitige Programmierung ist ein Schlüsselaspekt der modernen Softwareentwicklung, da sie es Anwendungen ermöglicht, mehrere Aufgaben gleichzeitig auszuführen und so die Effizienz und Skalierbarkeit zu verbessern. Die Go-Sprache eignet sich aufgrund ihrer hervorragenden Parallelitätsunterstützung ideal für die Erstellung gleichzeitiger Anwendungen.

Goroutine-Grundlagen

Goroutine ist ein leichter Thread in Go, der mit dem Schlüsselwort go gestartet wird. Sie unterscheiden sich von Threads dadurch, dass sie denselben Speicherplatz teilen, aber in unterschiedlichen Ausführungsströmen ausgeführt werden. go关键字启动。它们与线程不同，因为它们共享相同的内存空间，但运行在不同的执行流中。

在Go中创建一个Goroutine示例代码：

package main

import "fmt"

func main() {
    go func() {
        fmt.Println("Hello from goroutine")
    }()
    fmt.Println("Hello from main")
}

此代码创建一个Goroutine，它并发打印Hello from goroutine，同时主Goroutine打印Hello from main。

通道用于通信

管道是Goroutine之间通信的一种机制。它们类似于缓冲队列，Goroutine可以使用它们发送和接收消息。

创建一个通道的示例代码：

package main

import "fmt"

func main() {
    c := make(chan int)
    go func() { c <- 10 }()
    v := <-c
    fmt.Println(v)
}

此代码创建一个管道c，一个Goroutine向通道发送值10，而主Goroutine从通道接收值并打印。

同步与等待

在并发编程中，同步对于确保Goroutine之间协调执行至关重要。Go提供了各种同步原语，例如互斥体、条件变量和等待组。

使用互斥体保护共享数据示例代码：

package main

import (
    "fmt"
    "sync"
)

func main() {
    var m sync.Mutex
    var count int
    go func() {
        m.Lock()
        count++
        m.Unlock()
    }()
    m.Lock()
    fmt.Println(count)
    m.Unlock()
}

此代码使用互斥体m来确保只有单个Goroutine可以同时访问count

package main

import (
    "fmt"
    "log"
    "net/http"
)

func main() {
    http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
        go func() { fmt.Fprintf(w, "Hello, %s!", r.URL.Path[1:]) }()
    })
    log.Fatal(http.ListenAndServe(":8080", nil))
}

Nach dem Login kopieren

Dieser Code erstellt eine Goroutine, die gleichzeitig Hello from goroutine ausgibt, während die Haupt-Goroutine Hello from main ausgibt.

Kanäle werden für die Kommunikation verwendet

Pipelines sind ein Mechanismus für die Kommunikation zwischen Goroutinen. Sie ähneln Pufferwarteschlangen und können von Goroutinen zum Senden und Empfangen von Nachrichten verwendet werden.

Beispielcode zum Erstellen eines Kanals:

rrreee

Das obige ist der detaillierte Inhalt vonGolang Concurrency Programming Guide: Erkundung der Geheimnisse der Parallelverarbeitung. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!