concurrency - sync.WaitGroup不等待

可能是我看不到明显的东西，我在做什么错:

func printSize (listOfUrls []string){
    var wg sync.WaitGroup
    wg.Add(len(listOfUrl))
    for _, myurl := range(listOfUrls){
        go func(){
               body := getUrlBody(myurl)
               fmt.Println(len(body))
               wg.Done()
           }()
    }
    wg.Wait()
}

如果删除wg并走，我将正确接收每个URL主体的大小。如果我像上面那样做，它几乎立即打印零。 getUrlBody()有时需要花费几分钟才能执行。

回答评论:可以肯定的是，我也尝试过这种方法，并且表现出相同的行为。
我发现错误发生在getUrlBody和main()函数中...

func printSize(listOfUrls []string) {
    var wg sync.WaitGroup
    wg.Add(len(listOfUrls))
        for _, myurl := range listOfUrls {
          go f(myurl, &wg)
        }
    wg.Wait()
}

func f(myurl string, wg *sync.WaitGroup) {
    body := getUrlBody(myurl)
    fmt.Println(len(body))
    wg.Done()
 }

最佳答案

所有goroutine都共享单个myurl变量。有关更多信息，请参见https://golang.org/doc/faq#closures_and_goroutines。

将代码更改为:

func f(listOfUrls []string){
  var wg sync.WaitGroup
  wg.Add(len(listOfUrl))
  for _, myurl := range(listOfUrls){
    go func(myurl string){
           body := getUrlBody(myurl)
           fmt.Println(len(body))
           wg.Done()
       }(myurl)
  }
  wg.Wait()
}

要么

func f(listOfUrls []string){
  var wg sync.WaitGroup
  wg.Add(len(listOfUrl))
  for _, myurl := range(listOfUrls){
    myurl := myurl
    go func(){
           body := getUrlBody(myurl)
           fmt.Println(len(body))
           wg.Done()
       }()
  }
  wg.Wait()
}