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