Go语言中的并发map

2020-02-01  本文已影响0人  码二哥

参考:
http://c.biancheng.net/view/34.html

关键点

希望能通过下面的关键点,能够快速的复习,掌握核心点

1、使用sync.Map来实现并发map,但并发go语言原生自带

2、使用sync.Map 不需要初始化,直接声明一个变量就可以用了

  • var add sync.Map,这样就可以,接下来就可以直接调用方法
  • sync.Map的声明,不能使用make进行创建

3、注意:
此并发map,并没有提供获取map数量的方法,需要自己自行遍历获得

4、普通map的并发

  • 只读,是线程安全的,
  • 同时读写,线程不安全

Go语言中的 map 在并发情况下,只读是线程安全的,同时读写是线程不安全的。

1、例子 1 并发情况下读写 map 时会出现的问题

代码如下:

// 创建一个int到int的映射
m := make(map[int]int)
// 开启一段并发代码
go func() {
    // 不停地对map进行写入
    for {
        m[1] = 1
    }
}()
// 开启一段并发代码
go func() {
    // 不停地对map进行读取
    for {
        _ = m[1]
    }
}()
// 无限循环, 让并发程序在后台执行
for {
}

运行代码会报错,输出如下:

fatal error: concurrent map read and map write

错误信息显示,并发的 map 读和 map 写,
也就是说使用了两个并发函数不断地对 map 进行读和写而发生了竞态问题,map 内部会对这种并发操作进行检查并提前发现

1.1、针对map,为什么不提倡加锁

需要并发读写时,一般的做法是加锁,但这样性能并不高
Go语言在 1.9 版本中提供了一种效率较高的并发安全的 sync.Map,sync.Map 和 map 不同,不是语言原生形态提供,而是在sync 包下的特殊结构

sync.Map 有以下特性:

使用 Range 配合一个回调函数进行遍历操作,通过回调函数返回内部遍历出来的值,Range 参数中回调函数的返回值在需要继续迭代遍历时,返回 true,终止迭代遍历时,返回 false。

2、例子 2 并发安全的 sync.Map

演示代码如下:

package main
import (
      "fmt"
      "sync"
)
func main() {
    var scene sync.Map
    
    // 将键值对保存到sync.Map
    scene.Store("greece", 97)
    scene.Store("london", 100)
    scene.Store("egypt", 200)

    // 从sync.Map中根据键取值
    fmt.Println(scene.Load("London"))
    
    // 根据键删除对应的键值对
    scene.Delete("London")
    
    // 遍历所有sync.Map中的键值对
    scene.Range(func(k, v interface{}) bool {
        fmt.Println("iterate:", k, v)
        return true
    })
}

代码输出如下:

100 true
iterate: egypt 200
iterate: greece 97

代码说明如下:

image

2.1、sync.Map 没有提供获取 map 数量的方法

替代方法是在获取 sync.Map 时遍历自行计算数量

sync.Map 为了保证并发安全有一些性能损失,因此在非并发情况下

使用 map 相比使用 sync.Map 会有更好的性能。

上一篇 下一篇

猜你喜欢

热点阅读