首页 文章

WaitGroup goroutines with channel

提问于
浏览 次
1

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

代码：

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上树了它

go

2 回答

  • 0

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

    如果您在 wg.Done() 之后放置 time.Sleep(time.Second * 1) 之类的内容，您将能够看到所有输出行 .

    回复于
  • 3

    上述博客以下面的评论开头：

    编辑：正如本期Reddit评论中的effenn指出的那样，本文中的大量信息“危险地不准确” . OOPS！我在这里写了一篇后续/修正文章，供你观赏，但我将这篇文章留给“历史目的” .

    Reddit comment和followup article都描述了问题并为您的问题提供了解决方案 . （添加 time.Sleep(...) 使程序以您期望的方式工作真的很笨拙......）

    回复于

相关问题