Go語(yǔ)言并發(fā)安全有哪些例子

小樊
81
2024-10-25 21:49:07

Go語(yǔ)言的并發(fā)安全體現(xiàn)在多個(gè)方面，以下是一些并發(fā)安全的例子：

  1. sync.Mutex互斥鎖：這是Go語(yǔ)言提供的用于保護(hù)共享資源的同步原語(yǔ)。當(dāng)一個(gè)goroutine持有一個(gè)互斥鎖時(shí)，其他goroutine不能獲取該鎖，從而保證了同一時(shí)間只有一個(gè)goroutine能夠訪問(wèn)被保護(hù)的資源。例如：
var mu sync.Mutex
var counter int

func increment() {
    mu.Lock()
    defer mu.Unlock()
    counter++
}
  1. sync.RWMutex讀寫鎖：這是一種特殊的互斥鎖，允許多個(gè)goroutine同時(shí)讀取共享資源，但在寫入時(shí)會(huì)阻塞其他goroutine的讀取和寫入操作。這在讀操作遠(yuǎn)多于寫操作的場(chǎng)景下非常有用。例如：
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
}
  1. sync.WaitGroup等待組：用于等待一組goroutine完成執(zhí)行。通過(guò)調(diào)用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()
}
  1. channel通道：Go語(yǔ)言的channel是一種內(nèi)置的數(shù)據(jù)結(jié)構(gòu)，用于在不同的goroutine之間安全地傳遞數(shù)據(jù)。channel內(nèi)部處理了必要的鎖定和同步，因此可以安全地在多個(gè)goroutine之間傳遞消息或數(shù)據(jù)。例如：
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ù)具體需求選擇使用。

0 踩