Golang中的并发安全

并发安全

并发安全也叫线程安全,在并发中出现了数据的丢失,称为并发不安全。

map和slice都是并发不安全的。
 


slice在并发执行中不会报错,但是数据会丢失;
map在并发执行中会直接报错(fatal error: concurrent map writes)。


 
切片并发不安全

场景: 10000个协程同时添加切片
var s []int

func appendValue(i int) {
s = append(s, i)
}

func main() {
for i := 0; i < 10000; i++ { //10000个协程同时添加切片
go appendValue(i)
}

for i, v := range s { //同时打印索引和值
fmt.Println(i, ":", v)
}
}
输出:

 
没有到9999,说明有数据丢失

解决方法: 加锁
var s []int
var lock sync.Mutex //互斥锁
func appendValue(i int) {
lock.Lock() //加锁
s = append(s, i)
lock.Unlock() //解锁
}

func main() {
for i := 0; i < 10000; i++ {
go appendValue(i)
}
//sort.Ints(s) //给切片排序,先排完序再打印,和下面一句效果相同
time.Sleep(time.Second) //间隔1s再打印,防止一边插入数据一边打印时数据乱序
for i, v := range s {
fmt.Println(i, ":", v)
}
}
总结: slice在并发执行中不会报错,但是数据会丢失

map并发不安全

场景: 2个协程同时读和写
func main() {
m := make(map[int]int)
go func() { //开一个协程写map
for i := 0; i < 10000; i++ {
m[i] = i
}
}()

go func() { //开一个协程读map
for i := 0; i < 10000; i++ {
fmt.Println(m[i])
}
}()

//time.Sleep(time.Second * 20)
for {
;
}
}
输出:

 
解决方法:尽量不要做map的并发,如果用并发要加锁,保证map的操作要么读,要么写。
var lock sync.Mutex
func main() {
m:=make(map[int]int)
go func() { //开一个协程写map
for i:=0;i<10000 ;i++ {
lock.Lock() //加锁
m[i]=i
lock.Unlock() //解锁
}
}()
go func() { //开一个协程读map
for i:=0;i<10000 ;i++ {
lock.Lock() //加锁
fmt.Println(m[i])
lock.Unlock() //解锁
}
}()
time.Sleep(time.Second*20)
}

总结: map在并发执行中会直接报错

原文链接:https://blog.csdn.net/weixin_4 ... 97247

0 个评论

要回复文章请先登录注册