我如何等待多个其他 Goroutine 上的单个 Goroutine 响应？

最近发现不少小伙伴都对Golang很感兴趣，所以今天继续给大家介绍Golang相关的知识，本文《我如何等待多个其他 Goroutine 上的单个 Goroutine 响应？》主要内容涉及到等等知识点，希望能帮到你！当然如果阅读本文时存在不同想法，可以在评论中表达，但是请勿使用过激的措辞~

大家好，我从 Python3 过渡到 Go，所以我尝试重写我创建的库以获得更好的性能。

我面临着一个问题，因为我是 Golang XD 中的菜鸟，我使用有限的 API 来下载数百个 json，并且我希望尽可能使用更少的请求。 因此，在下载这些 json 时，使用的一些 URL 是重复的，我的第一个想法是在我的下载函数（ goroutine ）和每个 goroutine 之间传递一个 map[stringLink]*myJsonReceived ，然后在下载之前检查链接是否已被另一个 goroutine 处理，因此与其再次请求并浪费带宽+ API 调用，不如等待其他 goroutine 完成下载并从字典中获取它。

我有几个选择：

1) goroutine 必须检查链接是否在地图内（如果是），它每隔 0.05 秒检查字典内的指针是否仍然为 nil 或者包含 json。 （可能是最糟糕的方法，但它有效）

2）将 Goroutines 之间传递的映射更改为 (map[stringlink]chan myjson) 这可能是最有效的方法，但我不知道如何将单个消息发送到通道并由多个等待的 Goroutine 接收它。 p>

3) 我可以通过向结构体添加一个计数器来使用选项 (2)，每次 goroutine 发现该 url 已被请求时，它只需向计数器添加 +1 并等待来自通道的响应，当下载 goroutine 完成后会向通道发送 X 条消息。但这种方式会让我在地图上添加太多的锁，这会浪费性能。

注意：我需要在所有函数执行结束时使用地图将下载的 Json 保存到我的数据库中，以免再次下载它们。

预先感谢大家的帮助。

解决方案

我想要解决你的任务是我会使用 goroutine 池来解决这个问题。会有一个生产者在通道上发送 URL，并且工作协程将在该通道上接收 URL 来处理（获取）。一旦 URL“完成”，同一个工作 Goroutine 也可以将其保存到数据库中，或者将结果传递到“收集器”goroutine 的结果通道上，如果需要，该 Goroutine 可以按顺序完成保存。

这种构造设计可确保通道上发送的每个 URL 仅由一个工作 goroutine 接收，因此您不需要任何其他同步（在使用共享地图的情况下需要同步）。更多频道信息请参见What are golang channels used for?

相对于共享变量，Go 更倾向于 goroutine（通道）之间的通信。引用自Effective Go: Share by communicating：

不要通过共享内存进行通信；相反，通过通信来共享内存。

有关如何创建工作池的示例，请参阅 Is this an idiomatic worker thread pool in Go?

以上就是本文的全部内容了，是否有顺利帮助你解决问题？若是能给你带来学习上的帮助，请大家多多支持golang学习网！更多关于Golang的相关知识，也可关注golang学习网公众号。