分享
并发环境应用map的解决方案
Cedrus · · 3867 次点击 · · 开始浏览这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。
众所周知,golang的map是非协程安全的(go1.6版本以后,go1.6之前读安全),而并发读写map的需求应该是很普遍的。举例如下:
package main
import "fmt"
func main() {
a := make(map[int]bool, 0)
for i:=0;i<100;i++{
go func() {
for i := 0; i < 20000; i++ {
a[i] = false
fmt.Printf("%v %v\n",i,a[i])
}
}()
}
}
运行报错:
fatal error: concurrent map writes
1.9版本之前,官方提供的解决方案是自己封装个带同步锁的struct。例如:
package main
import (
"fmt"
"sync"
)
type SafeMap struct{
sync.RWMutex
data map[int]int
}
func main() {
a := SafeMap{data: make(map[int]int)}
for i:=0;i<100;i++{
go func() {
for j := 0; j < 20000; j++ {
a.Lock()
a.data[j] = i
fmt.Printf("%v %v\n", i, j)
a.Unlock()
}
}()
}
}1.9版本以后,sync包引入了sync.Map,性能比起之前的解决方案有比较大的提升:
package main
import (
"fmt"
"sync"
)
func main() {
a := new(sync.Map)
wg := new(sync.WaitGroup)
wg.Add(100)
for i:=0;i<100;i++{
go func() {
for j := 0; j < 100; j++ {
a.Store(i, j)
}
wg.Done()
}()
}
wg.Wait()
a.Range(func(key, value interface{}) bool {
fmt.Printf("%v %v\n", key, value)
return true
})
}
有疑问加站长微信联系(非本文作者)
入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889
关注微信3867 次点击
被以下专栏收入,发现更多相似内容
添加一条新回复
(您需要 后才能回复 没有账号 ?)
- 请尽量让自己的回复能够对别人有帮助
- 支持 Markdown 格式, **粗体**、~~删除线~~、
`单行代码` - 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
- 图片支持拖拽、截图粘贴等方式上传
收入到我管理的专栏 新建专栏
众所周知,golang的map是非协程安全的(go1.6版本以后,go1.6之前读安全),而并发读写map的需求应该是很普遍的。举例如下:
package main
import "fmt"
func main() {
a := make(map[int]bool, 0)
for i:=0;i<100;i++{
go func() {
for i := 0; i < 20000; i++ {
a[i] = false
fmt.Printf("%v %v\n",i,a[i])
}
}()
}
}
运行报错:
fatal error: concurrent map writes
1.9版本之前,官方提供的解决方案是自己封装个带同步锁的struct。例如:
package main
import (
"fmt"
"sync"
)
type SafeMap struct{
sync.RWMutex
data map[int]int
}
func main() {
a := SafeMap{data: make(map[int]int)}
for i:=0;i<100;i++{
go func() {
for j := 0; j < 20000; j++ {
a.Lock()
a.data[j] = i
fmt.Printf("%v %v\n", i, j)
a.Unlock()
}
}()
}
}1.9版本以后,sync包引入了sync.Map,性能比起之前的解决方案有比较大的提升:
package main
import (
"fmt"
"sync"
)
func main() {
a := new(sync.Map)
wg := new(sync.WaitGroup)
wg.Add(100)
for i:=0;i<100;i++{
go func() {
for j := 0; j < 100; j++ {
a.Store(i, j)
}
wg.Done()
}()
}
wg.Wait()
a.Range(func(key, value interface{}) bool {
fmt.Printf("%v %v\n", key, value)
return true
})
}