详尽解析go中的fatal error: concurrent map writes

背景

多个协程同时修改同一个map时报错

fatal error: concurrent map writes

原因

go中的map不是并发安全的，所以当多个goroutine同时对map执行写操作的时候，就会报刚刚的错误。

package main

import (
    "math/rand"
    "time"
)

func init() {
    rand.Seed(time.Now().UnixNano())
}

func main() {
    ConcurrentWrite()
}

func ConcurrentWrite() {
    m := make(map[int]int)

    f := func() {
        k, v := rand.Int()%50, rand.Int()%1000
        m[k] = v
    }
    for i := 0; i < 10; i++ {
        go f()
    }
    time.Sleep(time.Second * 5)
}

上面代码里，我们启动了10个协程对同一个map执行写操作，强制触发并发写。结果如下

fatal error: concurrent map writes
fatal error: concurrent map writes

go是如何检测到对map的并发写的

首先对map的写在源码上映射为 mapassign函数

// Like mapaccess, but allocates a slot for the key if it is not present in the map.
func mapassign(t *maptype, h *hmap, key unsafe.Pointer) unsafe.Pointer{
 ...
}

因为在这个函数里面执行写操作，那么panic也是在这里报出来的了。

我们忽略到无关的代码，先force在 concurrent map writes 报错。我们发现有如下代码

...
if h.flags&hashWriting != 0 { // h是指向map,
        throw("concurrent map writes")
}
...
// Set hashWriting after calling t.hasher, since t.hasher may panic,
// in which case we have not actually done a write.
h.flags ^= hashWriting // 位操作，把hasWriting 标志位记为1
...
// do wirte things
...
if h.flags&hashWriting == 0 {
  throw("concurrent map writes")
}
h.flags &^= hashWriting // 清空标志位

作者：admin

PHP面试网 站点 QQ交谈