Panduan Pengaturcaraan Golang Concurrency: Meneroka Misteri Pemprosesan Selari

Pengaturcaraan serentak dalam Go menggunakan benang ringan (Goroutine) dan mekanisme komunikasi (talian paip) untuk melaksanakan pelaksanaan tugas selari. Primitif penyegerakan (seperti mutex) digunakan untuk menyelaraskan akses antara Goroutines. Contoh praktikal termasuk mencipta perkhidmatan web serentak yang cekap untuk mengendalikan berbilang permintaan.

Panduan Pengaturcaraan Serentak dalam Go: Meneroka Misteri Pemprosesan Selari

Pengenalan

Pengaturcaraan serentak ialah aspek utama pembangunan perisian moden, membolehkan aplikasi melaksanakan pelbagai tugas secara serentak dan dengan itu meningkatkan kecekapan. Bahasa Go menjadikannya sesuai untuk membina aplikasi serentak melalui sokongan serentak yang sangat baik.

Asas Goroutine

Goroutine ialah utas ringan dalam Go, yang dimulakan dengan kata kunci go. Mereka berbeza daripada benang kerana mereka berkongsi ruang memori yang sama tetapi dijalankan dalam aliran pelaksanaan yang berbeza. 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))
}

Salin selepas log masuk

Kod ini mencipta Goroutine yang mencetak Hello dari goroutine manakala Goroutine utama mencetak Hello from main.

Saluran digunakan untuk komunikasi

Saluran paip ialah mekanisme komunikasi antara Goroutines. Ia serupa dengan baris gilir penimbal dan Goroutines boleh menggunakannya untuk menghantar dan menerima mesej.

Contoh kod untuk membuat saluran:

rrreee

Atas ialah kandungan terperinci Panduan Pengaturcaraan Golang Concurrency: Meneroka Misteri Pemprosesan Selari. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!