为什么这个函数在 golang 中不是线程安全的？

Question

这是我提到的代码：

// this is inside some method which has return signature like this: (*Data, error)
mapStore := make(...)
resSlice := make(...)
wg := new(sync.WaitGroup)
ec := make(chan error)
for keyString, sliceValue := range myMap {
     wg.Add(1)

     keyString := keyString
     sliceValue := sliceValue

     go func() {
          err := func(keyString string, sliceValue []Value, wg *sync.WaitGroup) error {
                defer wg.Done()
                res, err := process(keyString, sliceValue)
                if err != nil {
                      return errors.Wrapf(err, "wrong")
                }
                if res == nil {
                      return nil
                }
                if res.someData != nil {
                      mapStore[*res.someData] = append(mapStore[*res.someData], res)
                      return nil
                }
                resSlice := append(resSlice, res)
                return nil
               }(keyString, sliceValue, wg)
               if err != nil {
                     ec <- err
                     return
               }
          }()
     }
}
wg.Wait()

select {
case err := <- ec:
      return nil, err
default:
      return resSlice, nil
}

我被告知由于某种原因这不是线程安全的，但我不确定在哪里。我认为这是处理ec 中的错误的问题，但希望得到一些帮助！

Answer 1

我还没有全部分析过，但是从多个goroutines修改mapStore肯定是不安全的：

mapStore[*res.someData] = append(mapStore[*res.someData], res)

但作为一个起点，在race detector 下运行它。它会为你发现很多问题。

这显然也不安全：

resSlice := append(resSlice, res)

但它也并不完全符合您的想法。这会创建一个名为resSlice 的新局部变量，它会遮蔽外部变量，但它也会修改外部变量（参见下面的 cmets）。除了两个东西可能同时尝试追加并发生冲突之外，append 可以在需要重新分配时将整个切片移动到内存中，因此即使您在其周围加了锁，这也会导致线程安全问题。

通常，您不想让每个 goroutine 更新某个中心变量，而是希望每个 goroutine 将其结果传递回一个通道。然后让主函数收集所有值并更新变量。有关示例，请参阅Go Concurrency Patterns: Pipelines and cancellation。