Проблемы с goroutines в цикле

Question

Я пытаюсь решить эту проблему на Exercism:

Write a program that counts the frequency of letters in texts using parallel computation.

В принципе, у меня есть тип FreqMap:

type FreqMap map[rune]int 

И в Frequency функции:

func Frequency(s string) FreqMap { 
    m := make(FreqMap) 
    for _, v := range s { 
     m[v]++ 
    } 
    return m 
} 

Exercism представляет собой пример реализации параллельной версии используя рекурсию, но я хотел бы реализовать свою собственную версию, используя цикл for. Я придумал следующее решение, которое не работает:

func ConcurrentFrequency(l []string) FreqMap { 
    c := make(chan FreqMap) 
    for i := 0; i < len(l); i++ { 
     go func(i int) { 
      c <- Frequency(l[i]) 
     }(i) 
    } 
    return <- c 
} 

Это, кажется, вернуться только после 1 итерации, c, кажется, содержит результат только 1 goroutine; Я получаю тот же результат, если добавлю sync.WaitGroup.

Не могли бы вы объяснить, что мне здесь не хватает?

Заранее благодарю вас за помощь!

Answer 1

Ваш код, кажется, делает только одну итерацию, потому что ConcurrentFrequency возвращает первое значение из канала и это его. Я Quess вы хотите что-то вроде этого:

func ConcurrentFrequency(l []string) chan FreqMap { 
    c := make(chan FreqMap) 
    go func() { 
     var wg sync.WaitGroup 
     wg.Add(len(l)) 
     for _, s := range l { 
      go func(s string) { 
       defer wg.Done() 
       c <- Frequency(s) 
      }(s) 
     } 
     wg.Wait() 
     close(c) 
    }() 
    return c 
} 

Теперь возвращает канал карты, это вы probaly хотите объединить в Сигле карте:

func main() { 
    m := make(FreqMap) 
    for v := range ConcurrentFrequency([]string{"foo", "bar","zoo"}) { 
     for k, v := range v { 
      m[k] += v 
     } 
    } 
    fmt.Println(m) 
} 

---

более пространное объяснение, что не делает вписывается в комментарий:

В петле for _, s := range l все горуты записываются в один и тот же канал, но поскольку этот канал не является буфером ed, как только первое значение записывается в него, оно «полно», что означает, что в него не могут быть записаны никакие другие значения. Таким образом, только один горутин в цикле может завершиться, и wg.Done вызывается только один раз. Таким образом, если исходный массив имеет более одной строки, остальные гориты не могут завершиться, пока что-то не начнет потреблять значения из канала. Но в вашей версии он застрял бы в wg.Wait, поскольку не все goroutines сделаны, и поэтому ConcurrentFrequency не может вернуть канал потребителю. В том, как я написал ConcurrentFrequency, cannel может быть возвращен потребителю, и это (чтение с канала) позволяет другим вызовам записать в канал.