并发模式

我们可以将流水线理解为一组由通道连接并由 goroutine 处理的阶段。每个阶段都被定义为执行特定的任务，并按顺序执行，下一个阶段在前一个阶段完成后开始执行。

流水线的另一个重要特性是，除了连接在一起，每个阶段都使用前一个阶段的结果并对其进行处理，直到获得最终结果。

为了阐明这些“理论”，让我们举一个小例子。在这个例子中，我们将看到流水线如何运作。

对于这个例子，我们将定义四个函数，这些函数将模拟流水线的不同阶段，我们不会定义任何逻辑，只是使用“time.Sleep”来模拟处理，并且每个函数的“执行时间”（由睡眠时间模拟）将是不同的。

此外，我们将定义四个通道，它们将作为每个“处理过程”的输入/输出，这将帮助我们理解前面提到的“每个流水线阶段由通道控制，并在前一步骤完成后执行”。

在这个例子中，我们只是将一个字符串与当前流水线阶段的相关值连接起来。

Output:

很棒！现在我们知道了如何在项目中开始实现这种并发模式的基础。