范围限制阻塞的缓冲通道

在IT行业这个发展更新速度很快的行业，只有不停止的学习，才不会被行业所淘汰。如果你是Golang学习者，那么本文《范围限制阻塞的缓冲通道》就很适合你！本篇内容主要包括##content_title##，希望对大家的知识积累有所帮助，助力实战开发！

我一定是脑子有问题，但是在迭代缓冲通道时我被阻塞了

    results := []search.book{}
    resultsstream := make(chan []search.book, 2)
    defer close(resultsstream)

    // parallelize searches to optimize response time
    for _, src := range sources {
        go src.search(bookname, resultsstream)
    }

    counter := 0
    for sourceresults := range resultsstream {
        counter = counter + 1
        results = append(results, sourceresults...)

        fmt.println(counter)
    }

    fmt.println("never called")

输出

1
2

这证明了 2 个源填充了通道（这是最大容量）。 我在这里缺少什么？ never called 是，嗯，从未被调用。

编辑

    var wg sync.WaitGroup
    results := []search.Book{}
    resultsStream := make(chan []search.Book, len(sources))
    defer close(resultsStream)

    // parallelize searches to optimize response time
    for _, src := range sources {
        wg.Add(1)
        go src.Search(bookName, resultsStream, &wg)
    }

    wg.Wait()
    close(resultsStream)
    for sourceResults := range resultsStream {
        results = append(results, sourceResults...)
    }

    c.JSON(http.StatusOK, gin.H{
        "results": results,
    })

正确答案

循环 for sourceResults := range resultsStream 重复从通道接收值，直到关闭。一旦发送者完成并关闭通道循环就会结束。

您可以为每个并行搜索创建新通道，一旦所有工作协程完成，您就可以关闭该通道。这将结束接收器循环（注意：不要从接收器端关闭通道，因为发送者不会知道并且发送到关闭的通道会导致恐慌）。

文中关于的知识介绍，希望对你的学习有所帮助！若是受益匪浅，那就动动鼠标收藏这篇《范围限制阻塞的缓冲通道》文章吧，也可关注golang学习网公众号了解相关技术文章。