Go語言作為一種并發(fā)編程語言，提供了豐富的同步機(jī)制來幫助開發(fā)者處理并發(fā)問題。掌握這些同步機(jī)制對于提升并發(fā)編程技能至關(guān)重要。本文將通過具體的代碼示例來說明Go語言中的一些常見同步機(jī)制，幫助讀者更好地理解并運用這些機(jī)制。
1. 互斥鎖（Mutex）
互斥鎖是一種基本的同步機(jī)制，用于保護(hù)共享資源不被多個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)
}
登錄后復(fù)制
在上面的示例中，通過sync.Mutex來保護(hù)counter變量的并發(fā)訪問，確保每次只有一個goroutine可以執(zhí)行incrementCounter()函數(shù)。
2. 通道（Channel）
通道是Go語言中一種用于在goroutine之間進(jìn)行通信的機(jī)制，它可以用來傳遞數(shù)據(jù)和控制并發(fā)。下面是一個簡單的通道示例：
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)
}
登錄后復(fù)制
在上面的示例中，通過通道ch在兩個goroutine之間傳遞數(shù)據(jù)。sendData()函數(shù)向通道發(fā)送數(shù)據(jù)，receiveData()函數(shù)從通道接收數(shù)據(jù)，通過range來遍歷通道中的數(shù)據(jù)。
3. 條件變量（Cond）
條件變量是一種在goroutine之間等待或發(fā)信號的機(jī)制，常用于實現(xiàn)一些復(fù)雜的同步邏輯。下面是一個簡單的條件變量示例：
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()
}
登錄后復(fù)制
在上面的示例中，通過條件變量cond和互斥鎖mutex來實現(xiàn)兩個goroutine之間的同步。worker1()函數(shù)等待done變量為true時才繼續(xù)執(zhí)行，worker2()函數(shù)設(shè)置done變量為true并發(fā)送信號給worker1()。
通過以上示例，希望讀者能夠更深入地理解Go語言中的同步機(jī)制，并在實際項目中靈活運用，提升并發(fā)編程技能。
