Почему в моем коде тупик даже после закрытия канала и выхода всех работников? - PullRequest
Новая
       40

Почему в моем коде тупик даже после закрытия канала и выхода всех работников?

0 голосов
/ 13 декабря 2018

Вот мой код: 

package main

import (
    "fmt"
    "sync"
)

func worker(id int, wg sync.WaitGroup, work <-chan int) {
    defer func() {
    wg.Done()
    fmt.Println("worker", id, "done")
    }()

    fmt.Println("worker", id, "started")

    for w := range work {
        fmt.Println("worker", id, "got work", w)
    }
}

func main() {

    work := make(chan int, 2)
    var wg sync.WaitGroup

    for i := 0; i < 3; i++ {
    wg.Add(1)
        go worker(i, wg, work)
    }

    // Generate work and send.
    for i := 0; i < 5; i++ {
        work <- i
    }

    close(work)

    fmt.Println("waiting ...")
    wg.Wait()
    fmt.Println("done")
}

Вот вывод: 

worker 2 started
worker 2 got work 0
worker 2 got work 1
worker 2 got work 2
worker 1 started
waiting ...
worker 0 started
worker 0 done
worker 1 got work 4
worker 1 done
worker 2 got work 3
worker 2 done
fatal error: all goroutines are asleep - deadlock!

goroutine 1 [semacquire]:
sync.runtime_Semacquire(0xc42001409c)
        /usr/local/Cellar/go/1.10.2/libexec/src/runtime/sema.go:56 +0x39
sync.(*WaitGroup).Wait(0xc420014090)
        /usr/local/Cellar/go/1.10.2/libexec/src/sync/waitgroup.go:129 +0x72
main.main()
        /Users/lone/bar/bar.go:39 +0x15f
exit status 2

Почему возник этот тупик?

1 Ответ

0 голосов
/ 13 декабря 2018

Из документов:

Группа WaitGroup не должна копироваться после первого использования.

Вместо этого попробуйте передать указатель на вашу рабочую функцию: 

func worker(id int, wg *sync.WaitGroup, work <-chan int)

Вот полный код: Детская площадка

...