Что такое предпочтительный способ синхронизации Goroutines

Question

У меня есть дорогостоящая функция, которую я применяю на всех предметах среза.Я использую GOROUTINES, чтобы иметь дело с этим, каждый Goroutine заниматься одним предметом среза.

func Huge(lst []foo) {
  for _, item := range lst {
     go performSlow(item)
  }

  // How do I synchronize here ?
  return someValue(lst)
}

.

Вопрос, как показано в комментарии, что является предпочтительным способом подождать всех Goroutines выполнила работу до вызова функции someValue?Переходя на канал для генеракодицетагкода и ожидания, пока все не записаны на нее работает, но кажется, что Overkill:

func Huge(lst []foo) {
  ch := make(chan bool)

  for _, item := range lst {
     go performSlow(item, ch)  // performSlow does its job, then writes a dummy value to ch
  }

  for i := range lst {
     _ = <-ch
  }

  return someValue(lst)
}

.

Есть лучший (то есть более эффективный и / или более идиоматический) способ сделать это?

Answer 1

Используйте Sync.waitgroup ( http://godoc.org/sync#waitgroup )

func Huge(lst []foo) {
  var wg sync.WaitGroup
  for _, item := range lst {
     wg.Add(1)
     go func() {
         performSlow(item)
         wg.Done()
     }()
  }

  wg.Wait()
  return someValue(lst)
}

.