map var 快照的并发读/写

Question

我遇到了我无法理解的情况。在我的代码中，我使用的函数需要读取地图（但不写入，仅循环遍历此地图中现有数据的快照）。有我的代码：

type MyStruct struct {
   *sync.RWMutex
   MyMap map[int]MyDatas
}

var MapVar = MyStruct{ &sync.RWMutex{}, make(map[int]MyDatas) }

func MyFunc() {
   MapVar.Lock()
   MapSnapshot := MapVar.MyMap
   MapVar.Unlock()
   for _, a := range MapSnapshot { // Map concurrent write/read occur here
      //Some stuff
   }
}

main() {
   go MyFunc()
}

函数“MyFunc”在一个goroutine中运行，只有一次，这个func没有多次运行。许多其他函数正在使用相同的方法访问相同的“MapVar”，并随机产生“映射并发写入/读取”。我希望有人能向我解释为什么我的代码是错误的。

感谢您的宝贵时间。

编辑：澄清一下，我只是在问为什么我的范围 MapSnapshot 会产生并发映射写入/读取。我无法理解如何同时使用此映射，因为我使用同步互斥体将真正的全局变量 (MapVar) 保存在本地变量 (MapSnapshot) 中。

编辑：已解决。要在不使用相同引用的情况下将映射的内容复制到新变量中（从而避免映射并发读/写），我必须遍历它并使用 for 循环将每个索引和内容写入新映射。

感谢 xpare 和 nilsocket。

Answer 1

这个函数没有多次运行。许多其他函数正在使用相同的方法访问相同的“MapVar”，并随机产生“map concurrent write/read”

当您将MapVar.MyMap 的值传递给MapSnapshot 时，Map concurrent write/read 将永远不会发生，因为该操作是用互斥体包装的。

但是在循环中，错误可能会发生，因为实际上读取过程是在循环期间发生的。所以最好用互斥锁来包装循环。

MapVar.Lock() // lock begin

MapSnapshot := MapVar.MyMap
for _, a := range MapSnapshot {
   // Map concurrent write/read occur here
   // Some stuff
}

MapVar.Unlock() // lock end

---

更新 1

以下是我对您的论点的回应：

这个for循环很费时间，这个循环里面东西很多，所以加锁会拖慢其他例程

根据你The function "MyFunc" is run in a go routine, only once, there is no multiple runs of this func的说法，那么我认为将MyFunc作为goroutine执行并不是一个好的选择。

为了提高性能，最好让循环内的进程在一个goroutine中执行。

func MyFunc() {
    for _, a := range MapVar.MyMap {
        go func(a MyDatas) {
           // do stuff here
        }(a)
    }
}

main() {
    MyFunc() // remove the go keyword
}

---

更新 2

如果你真的想复制 MapVar.MyMap 到另一个对象，将它传递给另一个变量将无法解决这个问题（map 与 int、float32 或其他 primitive 类型）。

请参考本帖How to copy a map?