如何使用互斥体在并发 Goroutines 中实现互斥？

使用互斥量的并发 Goroutine 中的互斥

互斥的概念控制着程序中函数或代码块的同时执行。在多个例程独立执行的并发编程环境中，保持互斥对于确保正确性和防止冲突至关重要。

问题：
考虑一个具有三个并发 goroutine 的场景（例程1、2 和 3)，它们交换数据并执行打印操作。目标是确保当任何 goroutine 中的特定代码部分正在执行时，其他 goroutine 中的执行会停止，直到该部分完成。

使用互斥体的解决方案：
互斥体，一个基本的同步原语，可以用来实现 goroutine 中的互斥。互斥体提供了一种锁定机制，一次只允许一个 goroutine 访问代码的关键部分。

在提供的代码片段中，引入了三个互斥体（mutex1、mutex2 和 mutex3）：

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

每个 goroutine 在执行临界区之前都会获取相应的互斥锁，如修改后的代码所示：

func Routine1() {
    mutex1.Lock()
    // do something
    ...
    // do something
    mutex1.Unlock()
    ...
}

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

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

• Routine1 在执行临界区时获取 mutex1，从而阻止其他例程的执行访问此部分。
• 例程 2 获取互斥体 2，确保其关键部分的独占执行。
• 例程 3 获取互斥体 3 以控制对其关键部分的访问。

等待组和同步：
此外，还使用了等待组（wg）来同步 goroutine：

wg.Add(3)
go Routine1()
go Routine2()
Routine3()
wg.Wait()

• Add 方法将等待组的计数器增加 3 ，表示三个 Goroutine 即将执行。
• go 语句 запускает Routine1 和 Routine2 并发。
• Routine3 在当前线程执行。
• Wait 方法会阻塞直到等待组计数器达到零，确保所有 goroutine 在主函数继续之前已完成执行。

结果：
通过此实现，关键部分的执行goroutine 将是互斥的。因此，每个例程中的打印操作不会重叠或交错，从而防止竞争条件并产生预期的输出。

以上是如何使用互斥体在并发 Goroutines 中实现互斥？的详细内容。更多信息请关注PHP中文网其他相关文章！