美文网首页
Go语言中的并发map

Go语言中的并发map

作者: 码二哥 | 来源:发表于2020-02-01 09:15 被阅读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 有以下特性:

  • 无须初始化,直接声明即可
  • sync.Map 不能使用 map 的方式进行取值和设置等操作,
  • 而是使用 sync.Map 的方法进行调用,
    • Store 表示存储,

    • Load 表示获取,

    • Delete 表示删除。

    • Range 配合一个回调函数进行遍历操作

使用 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

代码说明如下:

  • 第 7 行,声明 scene,类型为 sync.Map,注意,sync.Map 不能使用 make 创建。
  • 第 10~12 行,将一系列键值对保存到 sync.Map 中,sync.Map 将键和值以 interface{} 类型进行保存。
  • 第 15 行,提供一个 sync.Map 的键给 scene.Load() 方法后将查询到键对应的值返回。
  • 第 18 行,sync.Map 的 Delete 可以使用指定的键将对应的键值对删除。
  • 第 21 行,Range() 方法可以遍历 sync.Map,遍历需要提供一个匿名函数,参数为 k、v,类型为 interface{},每次 Range() 在遍历一个元素时,都会调用这个匿名函数把结果返回。
image

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

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

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

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

相关文章

  • Go语言中的并发map

    参考:http://c.biancheng.net/view/34.html 关键点 希望能通过下面的关键点,能够...

  • 第九章:Go语言映射类型map

    1. map概述 Go语言中map字典类型时散列表(hash table)的实现,因为Go语言中将map中的每个键...

  • Go语言高并发Map解决方案

    Go语言高并发Map解决方案 Go语言基础库中的map不是并发安全的,不过基于读写锁可以实现线程安全;不过在Go1...

  • Go Map 为什么是非线程安全的?

    Go map 默认是并发不安全的,同时对 map 进行并发读写的时,程序会 panic,原因如下:Go 官方经过长...

  • Go语言中的map并发读写问题

    初学Go语言,在使用内置数据结构map的时候遇到一个非常严重的问题。在我的应用场景下,服务端需要每隔一段时间定时从...

  • Golang goroutine 与 map 并发的采坑事件

    goroutine 与 map 并发的采坑事件 1. goroutine 与map 的并发读写操作 在Go 1.6...

  • 【go语言学习】映射map

    Go语言中的map(映射、字典)是一种内置的数据结构,它是一个无序的key-value对的集合。Go语言中的map...

  • 10.map

    Go语言基础之map | Golang Go语言中提供的映射关系容器为map,其内部使用散列表(hash)实现。 ...

  • go语言学习总结

    1、go语言的map和c++中的map有什么区别? go语言中的map是hash_table,和c++中uno...

  • 跟我一起学习GO语言008

    本节我们来看GO语言中的并发。 我们看并发,就不得不学习goroutine,goroutine是Go语言...

网友评论

      本文标题:Go语言中的并发map

      本文链接:https://www.haomeiwen.com/subject/jsutxhtx.html