带通道的 WaitGroup goroutine

Question

我正在WaitGroup从博客https://nathanleclaire.com/blog/2014/02/15/how-to-wait-for-all-goroutines-to-finish-executing-before-continuing/学习

代码：

package main

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

func main() {
    messages := make(chan int)
    var wg sync.WaitGroup

    // you can also add these one at 
    // a time if you need to 

    wg.Add(3)
    go func() {
        defer wg.Done()
        time.Sleep(time.Second * 3)
        messages <- 1
    }()
    go func() {
        defer wg.Done()
        time.Sleep(time.Second * 2)
        messages <- 2
    }() 
    go func() {
        defer wg.Done()
        time.Sleep(time.Second * 1)
        messages <- 3
    }()
    go func() {
        for i := range messages {
            fmt.Println(i)
        }
    }()

    wg.Wait()
}

我认为应该按顺序打印 3、2 和 1。但只打印了3、2，却少了1，这是什么问题呢？

您可以将其树在https://play.golang.org/p/kZCvDhykYM上

Answer 1

在latest之后，立即调用messages <- 1deferred ，它在程序结束时释放并退出。当程序退出时，所有 goroutine 都会被杀死，因此打印 goroutine 没有机会打印最新值。wg.Done()wg.Wait()

如果您time.Sleep(time.Second * 1)在后面添加类似的内容wg.Done()，您将能够看到所有输出行。