Параллелизм голанга: как добавить к одному и тому же срезу из разных горутин

Нет ничего плохого в защите MySlice = append(MySlice, &OneOfMyStructs) с помощью sync.Mutex. Но, конечно, у вас может быть канал результатов с размером буфера len(params), все горутины отправляют свои ответы, и как только ваша работа будет завершена, вы собираете данные из этого канала результатов.

Если ваш params имеет фиксированный размер:

MySlice = make([]*MyStruct, len(params))
for i, param := range params {
    wg.Add(1)
    go func(i int, param string) {
         defer wg.Done()
         OneOfMyStructs := getMyStruct(param)
         MySlice[i] = &OneOfMyStructs
     }(i, param)
}

Поскольку все горутины пишут в разную память, это не очень весело.

Ответ, отправленный @jimt, не совсем правильный, поскольку он пропускает последнее значение, отправленное в канале, и последнее defer wg.Done() никогда не вызывается. В приведенном ниже фрагменте есть исправления.

https://play.golang.org/p/7N4sxD-Bai

package main

import "fmt"
import "sync"

type T int

func main() {
    var slice []T
    var wg sync.WaitGroup

    queue := make(chan T, 1)

    // Create our data and send it into the queue.
    wg.Add(100)
    for i := 0; i < 100; i++ {
        go func(i int) {
            // defer wg.Done()  <- will result in the last int to be missed in the receiving channel
            queue <- T(i)
        }(i)
    }

    go func() {
        // defer wg.Done() <- Never gets called since the 100 `Done()` calls are made above, resulting in the `Wait()` to continue on before this is executed
        for t := range queue {
            slice = append(slice, t)
            wg.Done()   // ** move the `Done()` call here
        }
    }()

    wg.Wait()

    // now prints off all 100 int values
    fmt.Println(slice)
}

Канал - лучший способ решить эту проблему. Вот пример, который можно запустить на игровой площадке.

package main

import "fmt"
import "sync"
import "runtime"

type T int

func main() {
    var slice []T
    var wg sync.WaitGroup

    queue := make(chan T, 1)

    // Create our data and send it into the queue.
    wg.Add(100)
    for i := 0; i < 100; i++ {
        go func(i int) {
            defer wg.Done()

            // Do stuff.
            runtime.Gosched()

            queue <- T(i)
        }(i)
    }

    // Poll the queue for data and append it to the slice.
    // Since this happens synchronously and in the same
    // goroutine/thread, this can be considered safe.
    go func() {
        defer wg.Done()
        for t := range queue {
            slice = append(slice, t)
        }
    }()

    // Wait for everything to finish.
    wg.Wait()

    fmt.Println(slice)
}

Примечание. Вызов runtime.Gosched() существует потому, что эти горутины не подчиняются планировщику. Что приведет к тупиковой ситуации, если мы явно не сделаем что-то для запуска указанного планировщика. Другой вариант мог заключаться в выполнении некоторого ввода-вывода (например, печать в стандартный вывод). Но я считаю, что цель runtime.Gosched() проще и яснее.