Go中如何使用WaitGroups和Mutexes来实现并发goroutine之间的互斥？

使用 WaitGroup 和互斥体实现并发 Goroutines 的互斥

Go 中一次只有一个 Goroutine 的情况下实现并发 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中文网其他相关文章！