golang中map并发读写问题及解决方法
2017-03-04 17:35
966 查看
一、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串行化处理
如果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串行化处理
相关文章推荐
- 【GoLang笔记】遍历map时的key随机化问题及解决方法
- 关于golang的并发读写访问map问题
- golang map数据结构不能并发读写问题
- GDAL读写dxf文件中文乱码问题解决方法(二)
- 关于注册Google Map api key的方法和解决网页无法显示的问题
- LINUX的ORACLE 中实现PL/SQL读写文件 问题解决方法
- 大数据高并发问题解决方法
- sql读写图片时Image.FromStream方法提示参数错误问题解决
- isnan和hash_map使用问题解决方法
- Map的keySet方法序列化BUG问题及其解决方法
- wordcount程序出现map 100% reduce 0%问题的解决方法
- MySQL的myisam解决并发读写解决方法
- 事务并发时可能出现的问题及解决方法
- geotools读写shapefile文件汉字乱码问题的解决方法
- Mysql(MyISAM)的读写互斥锁问题的解决方法
- Xml文件并发读写的解决方法
- 多线程操作stl::map引起的数据不一致问题的解决过程与方法
- 多进程同时访问文件并发问题解决方法 .
- golang 中map并发读写操作
- hadoop问题Type mismatch in value from map解决方法