Kuasai mekanisme penyegerakan bahasa Go: tingkatkan kemahiran pengaturcaraan serentak

Sebagai bahasa pengaturcaraan serentak, bahasa Go menyediakan mekanisme penyegerakan yang kaya untuk membantu pembangun menangani isu konkurensi. Menguasai mekanisme penyegerakan ini adalah penting untuk meningkatkan kemahiran pengaturcaraan serentak anda. Artikel ini akan menggambarkan beberapa mekanisme penyegerakan biasa dalam bahasa Go melalui contoh kod khusus untuk membantu pembaca memahami dan menggunakan mekanisme ini dengan lebih baik.

1. Mutex (Mutex)

Mutex ialah mekanisme penyegerakan asas yang digunakan untuk melindungi sumber dikongsi daripada diakses oleh berbilang goroutine pada masa yang sama. Berikut ialah contoh kunci mutex mudah:

package main

import (
    "fmt"
    "sync"
)

var (
    counter int
    mutex   sync.Mutex
)

func incrementCounter() {
    mutex.Lock()
    defer mutex.Unlock()
    counter++
}

func main() {
    var wg sync.WaitGroup
    for i := 0; i < 10; i++ {
        wg.Add(1)
        go func() {
            defer wg.Done()
            incrementCounter()
        }()
    }
    wg.Wait()
    fmt.Println("Counter:", counter)
}

Dalam contoh di atas, sync.Mutex digunakan untuk melindungi pembolehubah counter daripada akses serentak, memastikan bahawa terdapat hanya satu demi satu Goroutine boleh melaksanakan fungsi incrementCounter(). sync.Mutex来保护counter变量的并发访问，确保每次只有一个goroutine可以执行incrementCounter()函数。

2. 通道（Channel）

通道是Go语言中一种用于在goroutine之间进行通信的机制，它可以用来传递数据和控制并发。下面是一个简单的通道示例：

package main

import "fmt"

func sendData(ch chan<- int) {
    for i := 0; i < 5; i++ {
        ch <- i
    }
    close(ch)
}

func receiveData(ch <-chan int) {
    for v := range ch {
        fmt.Println("Received:", v)
    }
}

func main() {
    ch := make(chan int)
    go sendData(ch)
    receiveData(ch)
}

在上面的示例中，通过通道ch在两个goroutine之间传递数据。sendData()函数向通道发送数据，receiveData()函数从通道接收数据，通过range来遍历通道中的数据。

3. 条件变量（Cond）

条件变量是一种在goroutine之间等待或发信号的机制，常用于实现一些复杂的同步逻辑。下面是一个简单的条件变量示例：

package main

import (
    "fmt"
    "sync"
)

var (
    done  bool
    cond  *sync.Cond
    mutex sync.Mutex
)

func worker1() {
    mutex.Lock()
    for !done {
        cond.Wait()
    }
    mutex.Unlock()
    fmt.Println("Worker 1: Done")
}

func worker2() {
    mutex.Lock()
    done = true
    cond.Signal()
    mutex.Unlock()
    fmt.Println("Worker 2: Signaled")
}

func main() {
    cond = sync.NewCond(&mutex)
    go worker1()
    go worker2()
}

在上面的示例中，通过条件变量cond和互斥锁mutex来实现两个goroutine之间的同步。worker1()函数等待done变量为true时才继续执行，worker2()函数设置done变量为true并发送信号给worker1()

Atas ialah kandungan terperinci Kuasai mekanisme penyegerakan bahasa Go: tingkatkan kemahiran pengaturcaraan serentak. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!