在Go語言中,實現并發安全主要依賴于以下幾個方面:
sync/atomic
包中的AddInt32
, AddInt64
, CompareAndSwapInt32
等。這些函數可以在多個goroutine之間安全地執行加法、減法等操作,而無需使用鎖。import (
"fmt"
"sync/atomic"
)
var counter int32
func main() {
wg := sync.WaitGroup{}
for i := 0; i < 10; i++ {
wg.Add(1)
go func() {
defer wg.Done()
atomic.AddInt32(&counter, 1)
}()
}
wg.Wait()
fmt.Println("Counter:", counter)
}
sync.Mutex
和sync.RWMutex
兩種互斥鎖,用于在多個goroutine之間同步訪問共享資源。互斥鎖可以確保同一時間只有一個goroutine訪問共享資源,從而避免并發安全問題。import (
"fmt"
"sync"
)
var counter int
var lock sync.Mutex
func main() {
wg := sync.WaitGroup{}
for i := 0; i < 10; i++ {
wg.Add(1)
go func() {
defer wg.Done()
lock.Lock()
counter++
lock.Unlock()
}()
}
wg.Wait()
fmt.Println("Counter:", counter)
}
sync.RWMutex
是一種讀寫鎖,允許多個goroutine同時讀取共享資源,但在寫入時會阻止其他goroutine訪問。這在讀操作遠多于寫操作的場景下可以提高性能。import (
"fmt"
"sync"
)
var data map[string]int
var rwLock sync.RWMutex
func main() {
data = make(map[string]int)
wg := sync.WaitGroup{}
// 寫入數據
for i := 0; i < 10; i++ {
wg.Add(1)
go func(i int) {
defer wg.Done()
key := fmt.Sprintf("key%d", i)
value := i * 2
rwLock.Lock()
data[key] = value
rwLock.Unlock()
}(i)
}
// 讀取數據
for i := 0; i < 10; i++ {
wg.Add(1)
go func(i int) {
defer wg.Done()
key := fmt.Sprintf("key%d", i)
rwLock.RLock()
value := data[key]
rwLock.RUnlock()
fmt.Printf("Key: %s, Value: %d\n", key, value)
}(i)
}
wg.Wait()
}
import (
"fmt"
"sync"
)
func main() {
var wg sync.WaitGroup
ch := make(chan int, 10)
// 生產者
for i := 0; i < 10; i++ {
wg.Add(1)
go func(i int) {
defer wg.Done()
ch <- i * 2
}(i)
}
// 消費者
for i := 0; i < 10; i++ {
wg.Add(1)
go func() {
defer wg.Done()
value := <-ch
fmt.Println("Value:", value)
}()
}
wg.Wait()
}
sync.WaitGroup
, sync.Once
, sync.Cond
等,用于在多個goroutine之間協調執行。總之,Go語言通過原子操作、互斥鎖、讀寫鎖、通道和同步原語等多種方式實現了并發安全。在實際開發中,可以根據具體場景選擇合適的并發安全策略。