golang中map并发读写问题及解决方法
一、map并發(fā)讀寫問題
如果map由多協(xié)程同時讀和寫就會出現(xiàn)?fatal?error:concurrent?map?read?and?map?write的錯誤
如下代碼很容易就出現(xiàn)map并發(fā)讀寫問題
func?main(){
c?:=?make(map[string]int)
???????go?func()?{//開一個協(xié)程寫map
????????????for?j?:=?0;?j?<?1000000;?j++?{
??????????????c[fmt.Sprintf("%d",?j)]?=?j
????????????}
???????}()
???????go?func()?{????//開一個協(xié)程讀map
?????????????for?j?:=?0;?j?<?1000000;?j++?{
?????????????????fmt.Println(c[fmt.Sprintf("%d",j)])
?????????????}
???????}()
?time.Sleep(time.Second*20)
}
?
?
?
多個協(xié)程同時寫也會出現(xiàn)fatal?error:?concurrent?map?writes的錯誤
如下代碼很容易出現(xiàn)map并發(fā)寫的問題
func main(){
c?:=?make(map[string]int)
for?i?:=?0;?i?<?100;?i++?{
????????go?func()?{ //開100個協(xié)程并發(fā)寫map
??????????????for?j?:=?0;?j?<?1000000;?j++?{
?????????????????????c[fmt.Sprintf("%d",?j)]?=?j
??????????????}
????????}()
????????}
???????time.Sleep(time.Second*20)??//讓執(zhí)行main函數(shù)的主協(xié)成等待20s,不然不會執(zhí)行上面的并發(fā)操作
}
?
二、出現(xiàn)問題的原因
因為map為引用類型，所以即使函數(shù)傳值調(diào)用，參數(shù)副本依然指向映射m,?所以多個goroutine并發(fā)寫同一個映射m，?寫過多線程程序的同學(xué)都知道，對于共享變量，資源，并發(fā)讀寫會產(chǎn)生競爭的，?故共享資源遭到破壞
?
三、解決方法
１、加鎖
(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
}
?
?
２、利用channel串行化處理
轉(zhuǎn)載于:https://www.cnblogs.com/williamjie/p/9933644.html
總結(jié)
以上是生活随笔為你收集整理的golang中map并发读写问题及解决方法的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： ArrayListLinkedList
- 下一篇： JAVA学习笔记系列4-Eclipse版