在Go語言中,并發安全可以通過以下幾種方式保障:
sync.Mutex
和sync.RWMutex
提供了互斥鎖的功能,可以用來保護共享資源。當一個goroutine獲取鎖時,其他goroutine必須等待直到鎖被釋放。import (
"fmt"
"sync"
)
var counter int
var lock sync.Mutex
func increment() {
lock.Lock()
counter++
lock.Unlock()
}
func main() {
wg := sync.WaitGroup{}
for i := 0; i < 100; i++ {
wg.Add(1)
go func() {
defer wg.Done()
increment()
}()
}
wg.Wait()
fmt.Println("Counter:", counter)
}
sync/atomic
包提供了一組原子操作函數,可以在不使用鎖的情況下對共享變量進行安全的操作。原子操作是不可中斷的,因此它們在并發環境中是安全的。import (
"fmt"
"sync/atomic"
)
var counter int32
func increment() {
atomic.AddInt32(&counter, 1)
}
func main() {
wg := sync.WaitGroup{}
for i := 0; i < 100; i++ {
wg.Add(1)
go func() {
defer wg.Done()
increment()
}()
}
wg.Wait()
fmt.Println("Counter:", counter)
}
import (
"fmt"
)
func increment(counter chan int) {
counter <- 1
}
func main() {
counter := make(chan int, 1)
counter <- 0
wg := sync.WaitGroup{}
for i := 0; i < 100; i++ {
wg.Add(1)
go func() {
defer wg.Done()
increment(counter)
}()
}
wg.Wait()
counter <- 0 // Close the channel after all goroutines are done
finalCounter := <-counter
fmt.Println("Counter:", finalCounter)
}
sync
包還提供了其他同步原語,如sync.WaitGroup
、sync.Once
等,可以用來實現并發安全的代碼。總之,Go語言通過提供互斥鎖、原子操作、通道等機制,可以幫助開發者輕松地實現并發安全的代碼。在實際開發中,應根據具體場景選擇合適的同步方式。