Go中如何使用WaitGroups和Mutexes來實現並發goroutine之間的互斥？

使用WaitGroup 和互斥體實現並發Goroutines 的互斥

Go 中一次只有一個Goroutine 的情況下實現並發互的斥可以執行某些程式碼，我們可以利用WaitGroup 和互斥體的組合。

WaitGroup 是一個同步原語，它允許我們等待一組 goroutine 完成執行後再繼續。另一方面，互斥鎖提供了互斥鎖機制，確保程式碼的關鍵部分不會同時被多個 goroutine 執行。

考慮以下範例程式碼：

<code class="go">package main

import (
    "fmt"
    "rand"
    "sync"
)

var (
    mutex1, mutex2, mutex3 sync.Mutex
    wg sync.WaitGroup
)

func Routine1() {
    mutex1.Lock()
    defer mutex1.Unlock() // Ensure mutex is always unlocked before returning
    // do something

    // Sending and printing events should be mutually exclusive
    for i := 0; i < 200; i++ {
        mutex2.Lock()
        defer mutex2.Unlock()
        mutex3.Lock()
        defer mutex3.Unlock()
        fmt.Println("value of z")
    }

    // do something
}

func Routine2() {
    mutex2.Lock()
    defer mutex2.Unlock()
    // do something

    // Sending and printing events should be mutually exclusive
    for i := 0; i < 200; i++ {
        mutex1.Lock()
        defer mutex1.Unlock()
        mutex3.Lock()
        defer mutex3.Unlock()
        fmt.Println("value of z")
    }

    // do something
}

func Routine3() {
    mutex3.Lock()
    defer mutex3.Unlock()
    // do something

    // Sending and printing events should be mutually exclusive
    for i := 0; i < 200; i++ {
        mutex1.Lock()
        defer mutex1.Unlock()
        mutex2.Lock()
        defer mutex2.Unlock()
        fmt.Println("value of z")
    }

    // do something
}

func main() {
    wg.Add(3)
    go Routine1()
    go Routine2()
    Routine3()
    wg.Wait() // Wait for all goroutines to complete
}</code>

在此程式碼中，我們有三個獨立的 goroutine（Routine1、Routine2 和 Routine3），它們都同時執行某些操作。然而，我們希望確保程式碼的某些部分（發送和列印事件）的執行不受其他 goroutine 的干擾。

我們透過利用互斥體來實現這一點。我們定義三個互斥體（互斥體 1、互斥體 2 和互斥體 3），並在執行臨界區之前取得對應互斥體的鎖。當一個互斥鎖被一個 goroutine 鎖定時，其他嘗試取得相同鎖的 goroutine 將被阻塞，直到該鎖變得可用。

透過鎖定和解鎖適當的互斥鎖，我們確保只有一個 goroutine 可以執行臨界區在任何給定時間。這可以防止這些程式碼段同時執行，並保持 goroutine 之間的互斥。

最後，我們使用 WaitGroup 來確保 main 函數在所有三個 goroutine 完成執行之前不會退出。這使我們能夠同步 goroutine 並控製程式的流程。

以上是Go中如何使用WaitGroups和Mutexes來實現並發goroutine之間的互斥？的詳細內容。更多資訊請關注PHP中文網其他相關文章！