追加関数: 同時アクセスに対してスレッドセーフではありません

for ループ内のスライスに要素を追加するためにゴルーチンを同時に使用すると、異常が発生しますデータ内で発生する可能性があります。結果のスライスに欠落したデータまたは空白のデータが表示される場合があり、データ競合の可能性を示しています。

これは、Go では同時読み取りと書き込みに対して本質的に安全な値がないために発生します。スライス ヘッダーによって表されるスライスも例外ではありません。提供されたコードは、同時アクセスによるデータ競合を示しています:

destSlice := make([]myClass, 0)

var wg sync.WaitGroup
for _, myObject := range sourceSlice {
    wg.Add(1)
    go func(closureMyObject myClass) {
        defer wg.Done()
        var tmpObj myClass
        tmpObj.AttributeName = closureMyObject.AttributeName
        destSlice = append(destSlice, tmpObj)
    }(myObject)
}
wg.Wait()

データ競合の存在を確認するには、次のコマンドを実行します。

go run -race play.go

出力により、データに関する警告が表示されます。レース:

WARNING: DATA RACE
...

同時実行性の問題の解決

この問題を解決するには、sync.Mutex:

var (
    mu        = &sync.Mutex{}
    destSlice = make([]myClass, 0)
)

var wg sync.WaitGroup
for _, myObject := range sourceSlice {
    wg.Add(1)
    go func(closureMyObject myClass) {
        defer wg.Done()
        var tmpObj myClass
        tmpObj.AttributeName = closureMyObject.AttributeName
        mu.Lock()
        destSlice = append(destSlice, tmpObj)
        mu.Unlock()
    }(myObject)
}
wg.Wait()

代わりに、チャネルを使用して追加を非同期的に処理することを検討してください:

var (
    appendChan = make(chan myClass)
    destSlice  = make([]myClass, 0)
)

var wg sync.WaitGroup
for _, myObject := range sourceSlice {
    wg.Add(1)
    go func(closureMyObject myClass) {
        defer wg.Done()
        var tmpObj myClass
        tmpObj.AttributeName = closureMyObject.AttributeName
        appendChan