如何实现一个通道、多个阅读器同时读取相同数据？

学习Golang要努力，但是不要急！今天的这篇文章《如何实现一个通道、多个阅读器同时读取相同数据？》将会介绍到等等知识点，如果你想深入学习Golang，可以关注我！我会持续更新相关文章的，希望对大家都能有所帮助！

我需要多个函数具有相同的通道作为参数并同时获取相同的数据。 这些函数中的每一个都有彼此独立的任务，但它们从相同的值开始。

例如，给定一个整数切片，一个函数计算其值的总和，另一个函数同时计算平均值。它们将是 goroutine。

一种解决方案是从一个值创建多个通道，但我想避免这种情况。我可能必须添加或删除功能，为此，我必须添加或删除频道。

我想我明白扇出模式可能是一种选择，但我不太明白它的实现。

解决方案

该问题针对 the rules of SO，因为它没有提出任何需要帮助的具体问题，而是要求辅导课程。

第一种方法，即所谓的“扇出”，是让所有消费者都有一个“个人”专用频道，复制要广播多次的值是消费者，并将每个副本发送到每个专用渠道。

表面上最自然的实现方法是有一个单一的通道，生产者可以将其工作单元发送到其中，而不关心有多少消费者读取它们，然后有一个专用的 goroutine 接收这些工作单元，复制他们每个人都将副本发送到消费者的专用渠道。

第二种方法是进入较低级别并使用 sync 包中的内容实现基本相同的方案。

可以想到以下方案：

• 拥有自定义 struct 类型，该类型具有保护类型状态的 sync.Mutex。
• 有一个字段可以保存多个消费者必须读取的值。
• 有一个该类型的计数器。
• 也有该类型的 sync.Cond。
• 那里也有一个容量为 1 的通道。

向消费者传达新的价值如下：

1. 锁定互斥锁。
2. 验证计数器是否为 0，否则会出现恐慌。
3. 将新值写入相应字段。
4. 将计数器设置为消费者数量。
5. 解锁互斥锁。
6. 脉冲 sync.Cond。

消费者应该在 sync.Cond 的等待调用中休眠。
一旦发送者发出脉冲，运行消费者代码的 goroutine 就会被唤醒并尝试读取该值。
值的读取如下所示：

1. 锁定互斥锁。
2. 验证计数器是否大于零，否则会出现恐慌。
3. 读取值。
4. 将计数器减一。
5. 如果计数器变为 0，则在该特殊通道上发送。
6. 解锁互斥锁。

需要通道向发送者传达所有消费者都已完成读取的信息：在尝试发送新值之前，消费者必须从该通道读取。

正如您可能看到的，第二种方法更加复杂且难以正确实施，因此我建议使用第一种方法。

我还想指出，您似乎缺乏关于如何实现并发运行和通信任务的某些背景知识。
我在此推荐阅读The Book以及至少The Blog的这些章节：

• Go Concurrency Patterns: Pipelines and cancellation。
• Go Concurrency Patterns: Timing out, moving on
• Advanced Go Concurrency Patterns

到这里，我们也就讲完了《如何实现一个通道、多个阅读器同时读取相同数据？》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于的知识点！