Go 多路复用器如何确保多个输入通道的公平和安全访问？

具有平等访问权限的通道多路复用器

这个 Go 多路复用器旨在将多个通道的输出合并为一个，确保每个输入通道都有输出通道的平等权利。然而，提供的测试给出了意想不到的结果。

问题分析

关键问题在于 Mux 函数生成的 goroutine。通道参数 c 旨在表示每个输入通道，在循环的每次迭代中都会更新。这意味着所有 goroutine 最终都会从同一个通道拉取，而不是它们预期的各个通道。

解决方案

要解决此问题，请将 goroutine 创建循环修改为通过每个 goroutine 的正确通道：

for _, c := range channels {
    go func(c <-chan big.Int) {
        ...
    }(c)
}

通过这样做，每个 goroutine 在以下情况下捕获通道的值：它被创建，消除了问题并产生了期望的结果。

提高并发安全

除了确保对输出通道的平等访问之外，确保对输出通道的平等访问也至关重要并发安全。初始代码使用 int 变量 n 来跟踪输入通道的关闭。然而，当 GOMAXPROCS 大于 1 时，多个 goroutine 有可能同时访问 n，从而可能导致竞争条件。

更安全的方法是使用sync.WaitGroup 对象，它允许 goroutine 相互等待并确保 n 被安全更新。使用sync.WaitGroup的修订后的代码：

import (
    "math/big"
    "sync"
)

// ... other code ...

// The channel to output to.
ch := make(chan big.Int, len(channels))

var wg sync.WaitGroup
wg.Add(len(channels))

// ... other code ...

// Close the channel when the pumping is finished.
go func() {
    // Wait for everyone to be done.
    wg.Wait()
    // Close.
    close(ch)
}()

通过这些修改，多路复用器现在可以正确且安全地运行，确保所有输入通道都可以平等地访问输出通道并避免竞争条件。

以上是Go 多路复用器如何确保多个输入通道的公平和安全访问？的详细内容。更多信息请关注PHP中文网其他相关文章！