фатальная ошибка: все рутины спят - тупик! при использовании WaitGroup с циклом for-select - PullRequest
Новая
       12

фатальная ошибка: все рутины спят - тупик! при использовании WaitGroup с циклом for-select

0 голосов
/ 12 октября 2019

go version: go1.12.5 linux / amd64

Я пытался понять ноль каналов в Go. 

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() никогда не вызывается, это означает, что горутин все еще жив.

Может ли кто-нибудь помочь мне понять, что здесь происходит

Ответы [ 2 ]

2 голосов
/ 12 октября 2019

Вы только закрываете ch, а не ch2. Когда ch закрыто, для процедуры устанавливается c1 на ноль, но c2 все еще не равно нулю, поэтому select ожидает получения от c2, а основная программа ожидает на wg.Done(), поэтому обе программыспят.

1 голос
/ 12 октября 2019

Это происходит потому, что вы не закрываете ch2. Блок выбора все еще ожидает 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()
}
...