Go 中缓冲通道的范围是阻塞的-Golang-PHP中文网

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

WBOY

发布： 2024-02-09 09:42:30

转载

676人浏览过

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,
    })

登录后复制