golang_并发安全: slice和map并发不安全及解决方法

并发安全

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

map和slice都是并发不安全的

切片并发不安全

场景: 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)
    }
}

结果：

8194 : 9923
8195 : 9924
8196 : 9925
8197 : 9926
8198 : 9927
8199 : 9928
8200 : 9929
8201 : 9930

没有到：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)
    }
}

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 {
        ;
    }
}

结果：

0
fatal error: concurrent map read and map write

解决方法：尽量不要做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)
}