让我们快速浏览一下 go 中的扇出模式。一般来说，扇出用于同时执行多个任务。

例如，假设您有一个数据管道，并且您想要处理各个项目。我们可以使用 go 例程和通道在收到项目时将其拆分，然后处理各个项目（例如输入 db）。

这是一个易于实现的简单模式；但你需要管理通道以防止死锁。

// produce is simulating our single input as a channel
func produce(id int) chan int {
    ch := make(chan int)
    go func() {
        for i := 0; i 



<p>这里的主要思想是有一个数据序列需要由固定数量的worker来操作。</p>

<p>对于输入，我们创建一个随机数序列并将它们放入通道中。我们将他们转移到另一个渠道，工人们将从中夺走他们的“工作”。 </p>

<p><em>在此示例中，并非绝对有必要将输入移至作业通道。我们可以轻松地让工作人员从输入通道中拉出；这里只是为了清楚起见而这样做。</em></p>

<p>然后我们将固定数量的工作线程作为 goroutine 发送出去。每个工作线程将从作业通道中拉取，直到没有更多数据需要处理，此时它向 waitgroup 发出信号，表明它已完成。</p>

<p>主线程使用 waitgroup 来确保它在所有工作人员完成之前不会完成，即所有作业都已处理完毕。</p>

<p>需要提到的一个关键点是，该模式并不对处理输入序列的顺序做出任何保证。在很多情况下这可能没问题。例如，输入序列是包含自己的时间戳的数据记录，目标是将记录存储在 db 中。在这种情况下，扇出是可以接受的。</p>

<p>最后一点，一旦序列中的所有数据都已发送，您将看到一些有关关闭通道的注释。这很关键。一旦没有更多数据，从通道中提取的范围运算符就会休眠。您可以通过注释掉一个将导致死锁情况的 close() 语句来验证这一点。 goroutines 和 channel 非常强大，但你必须明智地使用它们。</p>

<p>你会做什么不同的事情？我们如何改进这个例子？请在下面留下您的评论。</p>

<p>谢谢！</p>

<p><em>这篇文章以及本系列所有文章的代码可以在这里找到</em></p>