Go 中缓冲通道的范围是阻塞的

php小编鱼仔在Go语言中，缓冲通道是一种强大且灵活的工具。缓冲通道提供了一种在发送和接收数据之间进行同步的机制，可以控制通信的速度和顺序。它的范围是阻塞的，也就是说当通道已满或为空时，发送和接收操作将被阻塞，直到有足够的空间或数据可用。这种机制可以有效避免并发程序中的资源竞争和死锁问题，提高程序的可靠性和性能。通过合理使用缓冲通道，开发者可以更好地控制并发程序的执行流程，提升程序的效率和稳定性。

问题内容

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

    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 重复从通道接收值，直到关闭。一旦发送者完成并关闭通道循环就会结束。

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

以上是Go 中缓冲通道的范围是阻塞的的详细内容。更多信息请关注PHP中文网其他相关文章！