无论我关闭通道与否，地图缩小都不起效果

大家好，今天本人给大家带来文章《无论我关闭通道与否，地图缩小都不起效果》，文中内容主要涉及到，如果你对Golang方面的知识点感兴趣，那就请各位朋友继续看下去吧~希望能真正帮到你们，谢谢！

这是家庭作业和初学者问题。因为我发现了一个错误，所以我编辑了这个问题。

我正在尝试从文本中进行并行频率映射，但在最后一个操作（减少映射）中出现错误

到目前为止，代码似乎可以正常工作。

如果我关闭频道，则会收到错误消息： “恐慌：在封闭通道上发送”

如果我不关闭频道，我会得到： “致命错误：所有 goroutine 都在睡觉 - 死锁！”

func WordCount(text string) {

    text = strings.ToLower(text)
    re := regexp.MustCompile("\\w+")
    sentence := re.FindAllString(text, -1)

    numberOfGroups := 4
    piece := len(sentence) / numberOfGroups

    wordChannel := make(chan map[string]int)

    wg := new(sync.WaitGroup)
    wg.Add(numberOfGroups)

    for i := 0; i < numberOfGroups; i ++ {
        go processToCounting(sentence[i*piece:(i+1)*piece], wordChannel, wg)
    }

    wg.Wait()
    fmt.Print(<-wordChannel)
    fmt.Print("\n")

    finalMap := make(map[string]int)
    close(wordChannel)

    for i := 0; i < numberOfGroups; i++ {
        for k, v := range <- wordChannel {
            finalMap[k] += v
        }
    }
}

func processToCounting(textSlice []string, wordChannel chan map[string]int, wg *sync.WaitGroup) {
    freq := make(map[string]int)
    for _, v := range textSlice {
        freq[v]++
    }
    wg.Done()
    wordChannel <- freq
}

解决方案

1。第一个问题：恐慌

如果我关闭通道，我会收到错误：“恐慌：在关闭的通道上发送”

在当前版本的代码中，panic is not reproducible 带有我的测试语句，但您很容易导致此问题，例如如果您要在 wg.wait() 之前调用 close(wordchannel)。

让我们看看 processtocounting 中可能导致 panic 的 bug：

wg.done() // tells to the waitgroup that the gouroutine is done (decrements the counter of goroutines)
wordchannel <- freq // trying to write to the channel

这里 wg.done() 在实际写入通道之前向 waitgroup 发出信号，告知 goroutine 是 done。调用 goroutine（wordcount 函数）在某个时刻认为所有 goroutine 都已完成（wg.wait() 行）并关闭通道。但是你的一个尚未完成写入的 goroutine 会尝试写入已关闭的通道。然后你会得到panic。

如何修复：

在 processtocounting 函数中使用 defer

defer wg.done() // triggers wg.done right before the function returns (but after writing to the channel in your case)

阅读内容：

初学者请参阅A Tour of Go / Concurrency

在封闭的通道上发送会导致恐慌。

和文档：close

发送或关闭已关闭的通道会导致运行时恐慌。

2。第二个问题：死锁

如果我不关闭通道，我会得到：“致命错误：所有 goroutine 都在睡觉 - 死锁！”

您有一个从通道读取数据的 for 循环。这个for循环被永远锁定。等待来自通道的新值，但没有人会再在那里写入。

参见 A Tour of Go / Concurrency

循环 for i := range c 重复从通道接收值，直到关闭。

并查看 Channels 的文档

接收器总是阻塞，直到有数据要接收

问题1：为什么close(wordchannel)会触发panic

答：

1. 在将结果推送到通道之前放置 wg.done()
2. 该通道是非缓冲通道，这意味着它将被卡住以进行写入，直到有读取为止。但读取会在您关闭通道后发生。顺序是关闭通道 -> 读取通道 -> 写入通道 -> 恐慌

问题2：为什么会出现死锁。

a: fmt.print(<-wordchannel) 从通道读取一条消息，导致最后一个循环无法读取 numberofgroups 消息。它永远等待最后一条消息。

for i := 0; i < numberOfGroups; i++ {
        for k, v := range <- wordChannel {
            finalMap[k] += v
        }
    }

今天关于《无论我关闭通道与否，地图缩小都不起效果》的内容就介绍到这里了，是不是学起来一目了然！想要了解更多关于的内容请关注golang学习网公众号！