golang中map并发读写问题及解决方法

skh2015java · · 9285 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

一、map并发读写问题

如果map由多协程同时读和写就会出现 fatal error:concurrent map read and map write的错误

如下代码很容易就出现map并发读写问题

func main(){

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

 time.Sleep(time.Second*20)

}
 

 

 

多个协程同时写也会出现fatal error: concurrent map writes的错误

如下代码很容易出现map并发写的问题

func main(){

c := make(map[string]int)

for i := 0; i < 100; i++ {
        go func() {  //100个协程并发写map
              for j := 0; j < 1000000; j++ {
                     c[fmt.Sprintf("%d", j)] = j
              }
        }()
        }
       time.Sleep(time.Second*20)  //让执行main函数的主协成等待20s,不然不会执行上面的并发操作

}

 

二、出现问题的原因

因为map为引用类型,所以即使函数传值调用,参数副本依然指向映射m, 所以多个goroutine并发写同一个映射m, 写过多线程程序的同学都知道,对于共享变量,资源,并发读写会产生竞争的, 故共享资源遭到破坏

 

三、解决方法

1、加锁

(1)通用锁

type Demo struct {

  Data map[string]string 

  Lock sync.Mutex

}

 

func (d Demo) Get(k string) string{

  d.Lock.Lock()

  defer d.Lock.UnLock()

  return d.Data[k]

}

 

func (d Demo) Set(k,v string) {

  d.Lock.Lock()

  defer d.Lock.UnLock()

  d.Data[k]=v

}

 

 

(2)读写锁

type Demo struct {

  Data map[string]string 

  Lock sync.RwMutex

}

 

func (d Demo) Get(k string) string{

  d.Lock.RLock()

  defer d.Lock.RUnlock()

  return d.Data[k]

}

 

func (d Demo) Set(k,v string) {

  d.Lock.Lock()

  defer d.Lock.UnLock()

  d.Data[k]=v

}

 

 

2、利用channel串行化处理


有疑问加站长微信联系

本文来自:CSDN博客

感谢作者:skh2015java

查看原文:golang中map并发读写问题及解决方法

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:1006366459

9285 次点击  
加入收藏 微博
2 回复  |  直到 2017-07-20 16:37:59
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传