在Go語言中,有多種方法可以實現并發編程的同步。以下是一些常用的同步機制:
sync
包提供了Mutex
結構體和相關的方法,如Lock()
、Unlock()
等。使用Mutex時,需要注意避免死鎖問題。import (
"sync"
)
var mu sync.Mutex
var counter int
func increment() {
mu.Lock()
counter++
mu.Unlock()
}
sync
包提供了RWMutex
結構體和相關的方法,如RLock()
、RUnlock()
、Lock()
、Unlock()
等。import (
"sync"
)
var rwMu sync.RWMutex
var sharedData map[string]string
func readData(key string) {
rwMu.RLock()
defer rwMu.RUnlock()
value, ok := sharedData[key]
if !ok {
fmt.Println("Key not found")
} else {
fmt.Println("Value:", value)
}
}
func writeData(key, value string) {
rwMu.Lock()
defer rwMu.Unlock()
sharedData[key] = value
}
sync
包提供了WaitGroup
結構體和相關的方法,如Add()
、Done()
、Wait()
等。import (
"fmt"
"sync"
"time"
)
func worker(wg *sync.WaitGroup, id int) {
defer wg.Done()
fmt.Printf("Worker %d starting\n", id)
time.Sleep(time.Second)
fmt.Printf("Worker %d done\n", id)
}
func main() {
var wg sync.WaitGroup
for i := 1; i <= 5; i++ {
wg.Add(1)
go worker(&wg, i)
}
wg.Wait()
fmt.Println("All workers done")
}
fmt
包提供了make()
函數用于創建Channel。import (
"fmt"
"time"
)
func producer(ch chan<- int) {
for i := 0; i < 5; i++ {
ch <- i
time.Sleep(time.Second)
}
close(ch)
}
func consumer(ch <-chan int) {
for num := range ch {
fmt.Println("Received:", num)
time.Sleep(2 * time.Second)
}
}
func main() {
ch := make(chan int, 5)
go producer(ch)
consumer(ch)
}
這些同步機制可以根據具體場景和需求進行組合使用,以實現更復雜的并發編程模式。