通道多路复用器
问题:
尝试创建一个通道多路复用器将多个通道的输出合并为一个,程序员遇到意外行为并寻求以下指导问题:
答案:
代码使用 for 循环为每个通道创建 goroutine。然而,变量 c 在循环的每次迭代中都会更新,导致 goroutine 全部从同一通道读取。要解决此问题,应将通道直接传递给 goroutine:
for _, c := range channels { go func(c <-chan big.Int) { // ... }(c) }
代码初始化所有输出值设置为“false”,导致仅打印 false 值。这可以通过将行 fmt.Println(l) 替换为 fmt.Println(l.String()) 来解决。
喂食模式是由上述代码中的错误引起的,其中 goroutine 尝试从同一通道读取数据。上面的修复应该可以解决这个问题,并允许所有输入通道的平衡输出。
提供的多路复用器实现是一个基本的方法。对于需要更高性能或并发性的场景,替代选项可能会考虑通过通道或同步原语(如互斥体)传递消息。
以上是如何有效地复用多个通道并避免意外行为?的详细内容。更多信息请关注PHP中文网其他相关文章!