前言

在 Golang 中 map 不是并发安全的，自 1.9 才引入了 sync.Map ，sync.Map 的引入确实解决了 map 的并发安全问题，不过 sync.Map 却没有实现 len() 函数，如果想要计算 sync.Map 的长度，稍微有点麻烦，需要使用 Range 函数。

map 并发操作出现问题

  1. func main() {
  2.     demo := make(map[int]int)
  4.     go func() {
  5.         for j := 0; j < 1000; j++ {
  6.             demo[j] = j
  7.         }
  8.     }()
  10.     go func() {
  11.         for j := 0; j < 1000; j++ {
  12.             fmt.Println(demo[j])
  13.         }
  14.     }()
  16.     time.Sleep(time.Second * 1)
  17. }

执行输出：

  1. fatal error: concurrent map read and map write

sync.Map 解决并发操作问题

  1. func main() {
  2.     demo := sync.Map{}
  4.     go func() {
  5.         for j := 0; j < 1000; j++ {
  6.             demo.Store(j, j)
  7.         }
  8.     }()
  10.     go func() {
  11.         for j := 0; j < 1000; j++ {
  12.             fmt.Println(demo.Load(j))
  13.         }
  14.     }()
  16.     time.Sleep(time.Second * 1)
  17. }

执行输出：

  1. <nil> false
  2. 1 true
  4. ...
  6. 999 true

计算 map 长度

  1. func main() {
  2.     demo := make(map[int]int)
  4.     for j := 0; j < 1000; j++ {
  5.         demo[j] = j
  6.     }
  8.     fmt.Println("len of demo:", len(demo))
  9. }

执行输出：

  1. len of demo: 1000

计算 sync.Map 长度

  1. func main() {
  2.     demo := sync.Map{}
  4.     for j := 0; j < 1000; j++ {
  5.         demo.Store(j, j)
  6.     }
  8.     lens := 0
  9.     demo.Range(func(key, value interface{}) bool {
  10.         lens++
  11.         return true
  12.     })
  14.     fmt.Println("len of demo:", lens)
  15. }

执行输出：

  1. len of demo: 1000

小结

  1. Load 加载 key 数据
  2. Store 更新或新增 key 数据
  3. Delete 删除 key 数据
  4. Range 遍历数据
  5. LoadOrStore 如果存在 key 数据则返回，反之则设置
  6. LoadAndDelete 如果存在 key 数据则删除

以上，希望对你能够有所帮助。

推荐阅读