Go語言作為一種并發編程語言，提供了豐富的同步機制來幫助開發者處理并發問題。掌握這些同步機制對于提升并發編程技能至關重要。本文將通過具體的代碼示例來說明Go語言中的一些常見同步機制，幫助讀者更好地理解并運用這些機制。
1. 互斥鎖（Mutex）
互斥鎖是一種基本的同步機制，用于保護共享資源不被多個goroutine同時訪問。下面是一個簡單的互斥鎖示例：
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)
}
登錄后復制
在上面的示例中，通過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()。
通過以上示例，希望讀者能夠更深入地理解Go語言中的同步機制，并在實際項目中靈活運用，提升并發編程技能。
