GOLANG：学习goroutine让我陷入僵局

Question

我是一个 GO 新手，我正在尝试弄清楚 goroutines 是如何工作的以及如何同步它们。这是我写的一个简单的程序来了解它们：

package main

import (
        "fmt"
        "sync"
        "time"
)

func printAfterDelay(delay time.Duration, message string, wg *sync.WaitGroup) {
        time.Sleep(delay)
        fmt.Println(message)
        wg.Done()
}

func add(a int, b int, chan1 chan int, wg *sync.WaitGroup) {
        c := a + b
        chan1 <- c
        //close(chan1)
        wg.Done()
}

func printer(chan1 chan int, wg *sync.WaitGroup) {
        for result := range chan1 {
                //result := <-chan1
                //time.Sleep(2000 * time.Millisecond)
                fmt.Println(result)
        }
        close(chan1)
        wg.Done()
}

func main() {
        //var wg sync.WaitGroup
        wg := &sync.WaitGroup{}

        fmt.Println("Start...")

        wg.Add(1)
        go printAfterDelay(2000*time.Millisecond, "Try", wg)

        chan1 := make(chan int)
        wg.Add(1)
        go add(5, 4, chan1, wg)

        wg.Add(1)
        go add(3, 1, chan1, wg)

        wg.Add(1)
        go printer(chan1, wg)

        //time.Sleep(3000 * time.Millisecond)
        wg.Wait()

        fmt.Println("End")
}

add 函数接受两个 int，将它们相加并将结果传递给 chan。 printer 函数从 chan 获取结果并打印出来。这两个函数在 main() 中作为 goroutines 调用，所以我还传递了一个 WaitGroup 作为指针，它在调用 goroutines 之前递增，并在函数结束时递减。

无论如何，当我执行它打印的编译程序时：

Start...
9
4
Try
fatal error: all goroutines are asleep - deadlock!
goroutine 16 [semacquire]:
sync.runtime_Semacquire(0x18334008)
  /usr/lib/go/src/pkg/runtime/sema.goc:199 +0x37
sync.(*WaitGroup).Wait(0x183240e0)
  /usr/lib/go/src/pkg/sync/waitgroup.go:129 +0x12d
main.main()        
  /home/ettore/go/src/example/goroutine/main.go:52 +0x1e5

goroutine 19 [finalizer wait]:
runtime.park(0x80599e0, 0x814f000, 0x814e3e9)
  /usr/lib/go/src/pkg/runtime/proc.c:1369 +0x94
runtime.parkunlock(0x814f000, 0x814e3e9)       
  /usr/lib/go/src/pkg/runtime/proc.c:1385 +0x3
frunfinq()        
  /usr/lib/go/src/pkg/runtime/mgc0.c:2644 +0xc5
runtime.goexit()        
  /usr/lib/go/src/pkg/runtime/proc.c:1445

goroutine 23 [chan receive]:
main.printer(0x1831a090, 0x183240e0)        
  /home/ettore/go/src/example/goroutine/main.go:23 +0x46
created by main.main        
  /home/ettore/go/src/example/goroutine/main.go:49 +0x1d7

哪里有问题？

谢谢！

Answer 1

以下作品。我的意思是它不会陷入僵局。由于您在通道上的范围循环中具有打印机功能，因此它会在通道关闭后自动停止。我在接近尾声时添加了 3 秒的延迟，以便让 try 循环有时间打印。 Read the documentation though. It'll explain 100% of these details.

package main

import (
        "fmt"
        "sync"
        "time"
)

func printAfterDelay(delay time.Duration, message string, wg *sync.WaitGroup) {
        time.Sleep(delay)
        fmt.Println(message)

}

func add(a int, b int, chan1 chan int, wg *sync.WaitGroup) {
        c := a + b
        chan1 <- c
        wg.Done()
}

func printer(chan1 chan int, wg *sync.WaitGroup) {
        for result := range chan1 {
                fmt.Println(result)
        }
}

func main() {
        //var wg sync.WaitGroup
        wg := &sync.WaitGroup{}

        fmt.Println("Start...")

        go printAfterDelay(2000*time.Millisecond, "Try", wg)

        chan1 := make(chan int)
        wg.Add(1)
        go add(5, 4, chan1, wg)

        wg.Add(1)
        go add(3, 1, chan1, wg)

        go printer(chan1, wg)

        time.Sleep(3000 * time.Millisecond)
        wg.Wait()
    close(chan1)

        fmt.Println("End")
}

GOLANG：学习goroutine让我陷入僵局

GOLANG: Learning goroutine took me to a deadlock

deadlock

go

goroutine