在Go語言中,保證并發編程的線程安全主要依賴于以下幾個方面:
sync.Mutex
結構體來實現互斥鎖。import "sync"
var mu sync.Mutex
var counter int
func increment() {
mu.Lock()
defer mu.Unlock()
counter++
}
sync.RWMutex
結構體來實現讀寫鎖。import "sync"
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
}
sync/atomic
包來實現原子操作。import "sync/atomic"
var counter int64
func increment() {
atomic.AddInt64(&counter, 1)
}
func worker(done chan bool) {
// Do some work...
done <- true
}
func main() {
done := make(chan bool)
go worker(done)
<-done
}
sync
包還提供了許多其他的同步原語,如sync.WaitGroup
、sync.Once
等,可以用于實現更復雜的并發控制。總之,在Go語言中,保證并發編程的線程安全需要使用適當的同步原語來確保對共享資源的訪問是互斥或有序的。在實際編程中,應根據具體場景選擇合適的同步機制。