当前位置： > > > > 致命错误：所有 goroutine 都在睡觉 – 死锁！将 WaitGroup 与 for-select 循环一起使用时

致命错误：所有 goroutine 都在睡觉 – 死锁！将 WaitGroup 与 for-select 循环一起使用时

来源：stackoverflow
2024-04-30 10:03:37
0浏览
收藏

目前米云上已经有很多关于Golang的文章了，自己在初次阅读这些文章中，也见识到了很多学习思路；那么本文《致命错误：所有 goroutine 都在睡觉 – 死锁！将 WaitGroup 与 for-select 循环一起使用时》，也希望能帮助到大家，如果阅读完后真的对你学习Golang有帮助，欢迎动动手指，评论留言并分享~

问题内容

go版本： go1.12.5 linux/amd64

我试图理解 go 中的 nil 通道。

package main

import (
    "fmt"
    "sync"
)

func main() {
    ch := make(chan int)
    ch2 := make(chan int)
    wg := sync.waitgroup{}
    wg.add(1)
    go func(c1 chan int, c2 chan int, w *sync.waitgroup) {
        for c1 != nil || c2 != nil {
            fmt.println("in for")
            fmt.println(c1, c2)
            select {
            case v, ok := <-c1:
                if !ok {
                    c1 = nil
                    fmt.println("c1 closed")
                } else {
                    fmt.println(v, " recieved c1")
                }
            case v, ok := <-c2:
                if !ok {
                    c2 = nil
                } else {
                    fmt.println(v, " recieved c2")
                }
            }
        }
        fmt.println("called wg.done")
        wg.done()
    }(ch, ch2, &wg)
    for i := 0; i < 4; i++ {
        if i%2 == 0 {
            ch <- i
        } else {
            ch2 <- i
        }
    }
    close(ch)
    wg.wait()
}

并在标准输出上收到此输出：

in for
0xc000084060 0xc0000840c0
0  recieved c1
in for
0xc000084060 0xc0000840c0
1  recieved c2
in for
0xc000084060 0xc0000840c0
2  recieved c1
in for
0xc000084060 0xc0000840c0
3  recieved c2
in for
0xc000084060 0xc0000840c0
c1 closed
in for
<nil> 0xc0000840c0
fatal error: all goroutines are asleep - deadlock!

goroutine 1 [semacquire]:
sync.runtime_Semacquire(0xc00009a018)
        /usr/local/go/src/runtime/sema.go:56 +0x39
sync.(*WaitGroup).Wait(0xc00009a010)
        /usr/local/go/src/sync/waitgroup.go:130 +0x65
main.main()
        /home/ayush/projects/gojects/src/go-practice/nil-channels/main.go:44 +0x155

goroutine 18 [select]:
main.main.func1(0xc00009a010, 0xc000084060, 0xc0000840c0, 0xc00009a010)
        /home/ayush/projects/gojects/src/go-practice/nil-channels/main.go:17 +0x1e5
created by main.main
        /home/ayush/projects/gojects/src/go-practice/nil-channels/main.go:13 +0xce
exit status 2

但是根据代码和日志，wg.done() 从未被调用，这意味着 goroutine 仍然存在。

谁能帮我理解这里发生了什么？

解决方案

您仅关闭 ch，而不关闭 ch2。当ch关闭时，goroutine将c1设置为nil，但是c2仍然不是nil，所以select等待从c2接收，主goroutine在wg.done()zqbendcz处等待qb，所以两个 goroutine 都在睡觉。</p> <p>发生这种情况是因为您没有关闭 ch2。 select 块仍在等待 ch2。

工作代码：

package main

import (
    "fmt"
    "sync"
)

func main() {
    ch := make(chan int)
    ch2 := make(chan int)
    wg := sync.WaitGroup{}
    wg.Add(1)

    go func(c1 chan int, c2 chan int, w *sync.WaitGroup) {
        for c1 != nil || c2 != nil {

            select {
            case v, ok := <-c1:
                if !ok {
                    c1 = nil
                    fmt.Println("c1 closed")
                } else {
                    fmt.Println(v, " recieved c1")
                }
            case v, ok := <-c2:
                if !ok {
                    c2 = nil
                } else {
                    fmt.Println(v, " recieved c2")
                }
            }
        }

        fmt.Println("called wg.Done")
        wg.Done()
    }(ch, ch2, &wg)

    for i := 0; i < 4; i++ {
        if i%2 == 0 {
            ch <- i
            fmt.Println("sending to c1 ", i)
        } else {
            ch2 <- i
            fmt.Println("sending to c2 ", i)
        }
    }
    close(ch)
    close(ch2)
    wg.Wait()
}

今天带大家了解了的相关知识，希望对你有所帮助；关于Golang的技术知识我们会一点点深入介绍，欢迎大家关注米云公众号，一起学习编程~