致命错误 - 所有 Goroutines 都在睡觉！僵局

怎么入门Golang编程？需要学习哪些知识点？这是新手们刚接触编程时常见的问题；下面golang学习网就来给大家整理分享一些知识点，希望能够给初学者一些帮助。本篇文章就来介绍《致命错误 - 所有 Goroutines 都在睡觉！僵局》，涉及到，有需要的可以收藏一下

我很困惑为什么这段代码会死锁。我收到一个关于 goroutine 正在睡觉的致命错误。我使用 waitgroup 来同步并等待 goroutine 完成，并传递我创建的一个 waitgroup 的地址而不是复制。我尝试过使用和不使用缓冲区，但仍然如此。

package main

import (
    "fmt"
    "sync"
)


func findMax(nums []int32) int32{
    max:=nums[0]
    for _, n := range nums{
        if n > max{
            max = n
        }
    }
    return max
}

func findFreq(nums []int32,  n int32) int32{
    mp := make(map[int32]int32)
    for _, num := range nums{
        if _, ok := mp[num]; ok{
            mp[num]+=1
        }else{
            mp[num]=1
        }
    }
    if f, ok := mp[n]; ok{
        return f
    }else{
        return -1
    }
}

func performWork(ch chan int32, nums []int32, q int32, wg *sync.WaitGroup){
    defer wg.Done()
    seg:=nums[q-1:]
    max:=findMax(seg)
    freq:=findFreq(seg, max)
    ch <- freq
}

func frequencyOfMaxValue(numbers []int32, q []int32) []int32 {
    res := []int32{}
    var wg sync.WaitGroup
    ch := make(chan int32)
    
    for _, query := range q{
        wg.Add(1)
        go performWork(ch, numbers, query, &wg)
    }
    wg.Wait()
    for n := range ch{
        res=append(res, n)
    }
    return res

}
func main() {
  nums := []int32{5,4,5,3,2}
  queries:=[]int32{1,2,3,4,5}
  fmt.Println(frequencyOfMaxValue(nums,queries))
}

正确答案

工作线程被阻塞，等待主协程在通道上接收。主 goroutine 被阻塞，等待工作线程完成。陷入僵局！

假设您克服了这个僵局，还会出现另一个僵局。主协程在循环中接收 ch，但没有任何内容关闭 ch。

通过运行另一个 goroutine 在工作线程完成后关闭通道来消除死锁。

for _, query := range q {
    wg.Add(1)
    go performWork(ch, numbers, query, &wg)
}

go func() {
    wg.Wait() // <-- wait for workers
    close(ch) // <-- causes main to break of range on ch.
}()

for n := range ch {
    res = append(res, n)
}

文中关于的知识介绍，希望对你的学习有所帮助！若是受益匪浅，那就动动鼠标收藏这篇《致命错误 - 所有 Goroutines 都在睡觉！僵局》文章吧，也可关注golang学习网公众号了解相关技术文章。