为何在golang中这个函数不具备线程安全性？

本篇文章主要是结合我之前面试的各种经历和实战开发中遇到的问题解决经验整理的，希望这篇《为何在golang中这个函数不具备线程安全性？》对你有很大帮助！欢迎收藏，分享给更多的需要的朋友学习~

这是我提到的代码：

// 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 中的错误的问题，但希望得到一些帮助！

正确答案

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

mapstore[*res.somedata] = append(mapstore[*res.somedata], res)

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

这显然也是不安全的：

resSlice := append(resSlice, res)

但它也并不完全符合您的想法。这会创建一个名为 resslice 的新局部变量，它会隐藏外部变量，但它也会修改外部变量（请参阅下面的注释）。除了两个事物可能尝试同时追加并发生冲突这一事实之外，如果需要重新分配，append 还可以移动内存中的整个切片，因此即使您在其周围放置锁，这也可能会导致线程安全问题。

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

到这里，我们也就讲完了《为何在golang中这个函数不具备线程安全性？》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于的知识点！