Go語(yǔ)言的并發(fā)安全體現(xiàn)在多個(gè)方面,以下是一些并發(fā)安全的例子:
var mu sync.Mutex
var counter int
func increment() {
mu.Lock()
defer mu.Unlock()
counter++
}
var rwMu sync.RWMutex
var sharedData map[string]string
func readData(key string) string {
rwMu.RLock()
defer rwMu.RUnlock()
return sharedData[key]
}
func writeData(key, value string) {
rwMu.Lock()
defer rwMu.Unlock()
sharedData[key] = value
}
Add()
方法增加等待的goroutine數(shù)量,每個(gè)goroutine在執(zhí)行完畢前會(huì)調(diào)用Done()
方法減少計(jì)數(shù),而主goroutine可以通過(guò)Wait()
方法阻塞等待所有g(shù)oroutine完成。例如:var wg sync.WaitGroup
func worker(id int) {
defer wg.Done()
// 執(zhí)行任務(wù)
}
func main() {
for i := 0; i < 5; i++ {
wg.Add(1)
go worker(i)
}
wg.Wait()
}
ch := make(chan int)
go func() {
ch <- 42
}()
value := <-ch
fmt.Println(value) // 輸出:42
這些例子展示了Go語(yǔ)言中并發(fā)安全的常見實(shí)現(xiàn)方式。當(dāng)然,Go語(yǔ)言還提供了許多其他并發(fā)原語(yǔ)和工具,如sync.Once
、sync.Map
等,可以根據(jù)具體需求選擇使用。