Go 中的生成器并发模式：综合指南-Golang-PHP中文网

Go 中的生成器并发模式：综合指南

聖光之護

发布： 2024-12-25 15:03:01

原创

1175人浏览过

go并发模式：生成器模式详解及可视化

上一篇文章中，我们学习了Go语言并发编程的基础——goroutine和channel。此处链接到上一篇文章: 理解和可视化golang中的goroutine和channel 现在，让我们深入探讨如何将这些基础构建块组合成强大的模式来解决实际问题。本文将重点介绍生成器模式，并通过可视化图表帮助理解其工作原理。

Go 中的生成器并发模式：综合指南

生成器模式

生成器如同一个源源不断的喷泉，持续生成可在需要时使用的值。在Go中，它是一个函数，通过通道发送值流，允许程序其他部分按需接收这些值。

Go 中的生成器并发模式：综合指南

示例：

<code class="go">// generatenumbers 生成器函数，产生从1到max的数字
func generatenumbers(max int) chan int {
    out := make(chan int) // 创建通道发送数字
    go func() {
        defer close(out) // 完成后关闭通道，非常重要
        for i := 1; i <= max; i++ {
            out <- i // 发送数字到通道
        }
    }()
    return out // 返回通道给消费者
}</code>

登录后复制

这个生成器函数做了三件事：

创建一个通道发送值。
启动一个goroutine生成值。
立即返回通道供消费者使用。

为什么使用生成器？

将值生产和消费分离。
按需生成值（惰性求值）。
可以表示无限序列，而不会消耗无限内存。
允许并发地生产和消费值。

现实世界中的用例

逐行读取大文件：

<code class="go">func generatelines(filename string) chan string {
    out := make(chan string)
    go func() {
        defer close(out)
        // ... (文件打开、扫描、发送每一行到out通道的代码)...
    }()
    return out
}</code>

登录后复制

你可能会问，这有什么特别之处？我们也可以在没有goroutine的情况下生成数据序列或逐行读取文件。但这忽略了goroutine带来的优势。让我们比较两种情况的可视化：

没有goroutine:

所有数据生成完毕后才能开始处理。