duang8642 2015-12-29 18:59 采纳率: 0%
浏览 26

如何等待一组goroutines? [重复]

This question already has an answer here:

let's say I want to start a group of goroutines and than wait for all of them to finish (e.g. return). I can think of some channel-based solution (e.g. create a channel and listen to it counting received messages which shall be sent by each of goroutines and quiting after receive corresponding number of msgs) but maybe there's a more elegant/efficient solution because this case seems very common.

</div>
  • 写回答

1条回答 默认 最新

  • dsaf415212 2015-12-29 19:19
    关注

    Yes; you want a *sync.WaitGroup, which you can use by calling waitGroup.Add(1) before starting each task, waitGroup.Done() when it finishes, and waitGroup.Wait() once you have started everything and want to wait for it all to finish, like this:

    package main
    
    import (
        "fmt"
        "sync"
        "time"
    )
    
    func main() {
        wg := new(sync.WaitGroup)
        for i := 1; i < 3; i++ {
            wg.Add(1)
            go func(i int) { // ensures each run gets distinct i
                fmt.Println("Sleeping", i, "seconds")
                time.Sleep(time.Duration(i) * time.Second)
                fmt.Println("Slept", i, "seconds")
                wg.Done()
            }(i)
        }
        wg.Wait()
        fmt.Println("All done")
    }
    
    评论

报告相同问题?