Go - 使用 sync.Map 来解决 map 的并发操作问题

2021-11-01 15:36:40 浏览数 (1)

文章目录:

  • 前言
  • map 并发操作出现问题
  • sync.Map 解决并发操作问题
  • 计算 map 长度
  • 计算 sync.Map 长度
  • 小结
  • 推荐阅读

前言

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

map 并发操作出现问题

代码语言:javascript复制
func main() {
 demo := make(map[int]int)

 go func() {
  for j := 0; j < 1000; j   {
   demo[j] = j
  }
 }()

 go func() {
  for j := 0; j < 1000; j   {
   fmt.Println(demo[j])
  }
 }()

 time.Sleep(time.Second * 1)
}

执行输出:

代码语言:javascript复制
fatal error: concurrent map read and map write

sync.Map 解决并发操作问题

代码语言:javascript复制
func main() {
 demo := sync.Map{}

 go func() {
  for j := 0; j < 1000; j   {
   demo.Store(j, j)
  }
 }()

 go func() {
  for j := 0; j < 1000; j   {
   fmt.Println(demo.Load(j))
  }
 }()

 time.Sleep(time.Second * 1)
}

执行输出:

代码语言:javascript复制
<nil> false
1 true

...

999 true

计算 map 长度

代码语言:javascript复制
func main() {
 demo := make(map[int]int)

 for j := 0; j < 1000; j   {
  demo[j] = j
 }

 fmt.Println("len of demo:", len(demo))
}

执行输出:

代码语言:javascript复制
len of demo: 1000

计算 sync.Map 长度

代码语言:javascript复制
func main() {
 demo := sync.Map{}
 
 for j := 0; j < 1000; j   {
  demo.Store(j, j)
 }

 lens := 0
 demo.Range(func(key, value interface{}) bool {
  lens  
  return true
 })

 fmt.Println("len of demo:", lens)
}

执行输出:

代码语言:javascript复制
len of demo: 1000

小结

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

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

0 人点赞