我不明白为什么这适用于无缓冲通道，或者为什么需要等待组

Golang不知道大家是否熟悉？今天我将给大家介绍《我不明白为什么这适用于无缓冲通道，或者为什么需要等待组》，这篇文章主要会讲到等等知识点，如果你在看完本篇文章后，有更好的建议或者发现哪里有问题，希望大家都能积极评论指出，谢谢！希望我们能一起加油进步！

在此代码中，我调用一个函数来计算字符串中的字母数量，并返回符文映射。为了利用并发性，我使用 goroutine 调用该函数：

func concurrentfrequency(l []string) freqmap {
    var wg sync.waitgroup
    wg.add(len(l))
    m := freqmap{}

    // using unbuffered channel
    // ch := make(chan freqmap, len(l))
    ch := make(chan freqmap)

    for _, s := range l {
        go func(s string, ch chan<- freqmap) {
            defer wg.done()
            ch <- frequency(s)
        }(s, ch)
    }
    go func() {
        wg.wait()
        close(ch)
    }()

    for cm := range ch {
        for r, n := range cm {
            m[r] += n
        }
    }

    return m
}

如果我在不使用等待组和关闭通道的 goroutine 的情况下尝试此代码：

go func() {
        wg.wait()
        close(ch)
    }()

，然后我陷入僵局。

我不明白的是，为什么我能够循环无缓冲的通道，并从中读取多个地图。

这是完整的程序： https://go.dev/play/p/zuwr_hvtt5w

并发方法仅比顺序方法快一点：

goos: linux
goarch: amd64
pkg: letter
cpu: Intel(R) Core(TM) i5-6200U CPU @ 2.30GHz
BenchmarkSequentialFrequency
BenchmarkSequentialFrequency-2              2820            367128 ns/op           17571 B/op         13 allocs/op
BenchmarkConcurrentFrequency
BenchmarkConcurrentFrequency-2              4237            282632 ns/op           12682 B/op         72 allocs/op
PASS
ok      letter  3.320s

正确答案

A for-range loop over a channel continues until the channel is closed。

如果删除最终关闭通道的 goroutine，则 for 循环永远不会终止。一旦所有 goroutine 发送值完成，就只剩下一个 goroutine，并且它会永远阻塞，等待通道关闭。

缓冲通道与此问题无关。它们只帮助阻止发送者，但这里的问题是阻止接收者。

好了，本文到此结束，带大家了解了《我不明白为什么这适用于无缓冲通道，或者为什么需要等待组》，希望本文对你有所帮助！关注golang学习网公众号，给大家分享更多Golang知识！