内容简介：已知多个goroutine同时读写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此类解析方法也应避免使用，否则也会引发异常。
解决方案很多，控制同步使用，或者使用锁，这里就不多说了
以上就是本文的全部内容，希望本文的内容对大家的学习或者工作能带来一定的帮助，也希望大家多多支持 码农网
本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。
科技投资新时代：TMT投资方法、趋势与热点聚焦
马军、宋辉、段迎晟 / 人民邮电出版社 / 2018-3 / 69.00
中国 TMT 行业（科技、媒体及通信）起步较晚但充满朝气。2017 年，TMT 板块的IPO 数量占到了总数的四分之一；对于投资者来说，投资 TMT 的收益非常可观。那么，TMT 的投资趋势如何？ TMT 行业又有哪些投资热点？ 本书立足于 TMT 投资现状，在介绍了 TMT 投资的基本概念之后，作者详细讲述了TMT 投资的基本研究方法、分析视角、整体行情及趋势分析，同时从行业视角分析了包括......一起来看看 《科技投资新时代：TMT投资方法、趋势与热点聚焦》 这本书的介绍吧!
