Golang的map并发安全

已知多个goroutine同时读写Map会出问题
如下代码会抛出异常

package main
import (
    "time"
    "fmt"
)
func main()  {
    c := make(map[string]int)
    go func() {//开一个goroutine写map
        for j := 0; j < 1000000; j   {
            c[fmt.Sprintf("%d", j)] = j
        }
    }()
    go func() {    //开一个goroutine读map
        for j := 0; j < 1000000; j   {
            fmt.Println(c[fmt.Sprintf("%d",j)])
        }
    }()

    time.Sleep(time.Second*20)
}

运行结果

fatal error: concurrent map read and map write

由此可见golang中的map并不是并发安全的

那么同时进行len、encode、decode、或者同时write、read的操作呢？

以下进行测试

同时write和len（正常）

package main

import (
    "time"
    "fmt"
)

func main()  {
    c := make(map[string]int)
    go func() {//开一个goroutine写map
        for j := 0; j < 1000000; j   {
            c[fmt.Sprintf("%d", j)] = j
        }
    }()
    go func() {    //开一个goroutine读map
        for j := 0; j < 1000000; j   {
            //fmt.Println(c[fmt.Sprintf("%d",j)])
            fmt.Println(len(c))
        }
    }()

    time.Sleep(time.Second*20)
}

运行结果正常，当然，同时read和len也是ok的

同时write和json.Marshal（异常）

package main

import (
    "time"
    "fmt"
    "encoding/json"
)

func main()  {
    c := make(map[string]int)
    go func() {
        for j := 0; j < 1000000; j   {
            c[fmt.Sprintf("%d", j)] = j
        }
    }()
    go func() {
        for j := 0; j < 1000000; j   {
            json.Marshal(c)
        }
    }()
    time.Sleep(time.Second*20)
}

运行结果

fatal error: concurrent map iteration and map write

同时read和json.Unmarshal到同一个对象（异常）

package main

import (
    "time"
    "fmt"
    "encoding/json"
)

func main() {
    c := make(map[string]int)
    for j := 0; j < 100; j   {
        c[fmt.Sprintf("%d", j)] = j
    }
    b1,_:=json.Marshal(c)
    c2 := make(map[string]int)
    go func() { //开一个goroutine读map
        for j := 0; j < 1000000; j   {
            fmt.Println(c2[fmt.Sprintf("%d", j)])
        }
    }()
    go func() { //开一个goroutine读map
        for j := 0; j < 1000000; j   {
            json.Unmarshal(b1,&c2)
        }
    }()
    time.Sleep(time.Second * 20)
}

运行结果

fatal error: concurrent map read and map write

同时Read（正常）

package main

import (
    "time"
    "fmt"
    "encoding/json"
)

func main() {
    c := make(map[string]int)
    for j := 0; j < 1000000; j   {
        c[fmt.Sprintf("%d", j)] = j
    }
    go func() { //开一个goroutine读map
        for j := 0; j < 1000000; j   {
            fmt.Println(c[fmt.Sprintf("%d", j)])
        }
    }()
    go func() { //开一个goroutine读map
        for j := 0; j < 1000000; j   {
            fmt.Println(c[fmt.Sprintf("%d", j)])
        }
    }()
    time.Sleep(time.Second * 20)
}

运行结果正常

同时Write（异常）

import (
    "time"
    "fmt"
    "encoding/json"
)

func main() {
    c := make(map[string]int)
    go func() { //开一个goroutine写map
        for j := 0; j < 1000000; j   {
            c[fmt.Sprintf("%d", j)] = j
        }
    }()
    go func() { //开一个goroutine写map
        for j := 0; j < 1000000; j   {
            c[fmt.Sprintf("%d", j)] = j
        }
    }()
    time.Sleep(time.Second * 20)
}

运行结果

fatal error: concurrent map writes

结论：

1.无论什么情况下len操作总是正常的
2.同时read不会引发异常，同时read和write会异常，同时write会异常。
3.read或write的同时，json.Marshall或json.Unmarshall此类解析方法也应避免使用，否则也会引发异常。

解决方案很多，控制同步使用，或者使用锁，这里就不多说了

    原文作者：星落纷纷
    原文地址: https://www.jianshu.com/p/f2e7650da938
    本文转自网络文章，转载此文章仅为分享知识，如有侵权，请联系博主进行删除。

到此这篇关于“Golang的map并发安全”的文章就介绍到这了,更多文章或继续浏览下面的相关文章，希望大家以后多多支持JQ教程网！

您可能感兴趣的文章：
golang 并发访问map遇到的问题
Golang的map并发安全
golang：map
Golang线程安全Map:sync.Map使用小结
golang key map 所有_谨慎使用golang中的map
golang key map 所有_golang系列——高级语法之map
golang map 详解
go二维map_Golang使用Map的正确姿势
Golang map 并发读写问题源码分析
golang map 锁_golang中线程安全的map