您的位置:首页 > 教程 > 其他脚本 > gosync.Map基本原理深入解析

gosync.Map基本原理深入解析

2023-01-20 09:43:21 来源:易采站长站 作者:

目录
引言map 在并发下的问题map 并发读写异常的例子使用 sync.Mutex 保证并发安全使用 sync.RWMutex 保证并发安全有了读写锁为什么还要有 sync.Map?使用原子操作替代读锁锁跟原子操作的性能差多少?sync.Map 里面的原子操作sync.Map 的基本用法sync.Map 的使用场景总结

引言

我们知道,go>map 这种类型让我们可以存储键值对数据,但是如果我们在并发的情况下使用 map 的话,就会发现它是不支持并发地进行读写的(会报错)。 在这种情况下,我们可以使用 sync.Mutex 来保证并发安全,但是这样会导致我们在读写的时候,都需要加锁,这样就会导致性能的下降。

除了使用互斥锁这种相对低效的方式,我们还可以使用 sync.Map 来保证并发安全,它在某些场景下有比使用 sync.Mutex 更高的性能。 本文就来探讨一下 sync.Map 中的一些大家比较感兴趣的问题,比如为什么有了 map 还要 sync.Map?它为什么快?sync.Map 的适用场景(注意:不是所有情况下都快。)等。

关于 sync.Map 的设计与实现原理,会在下一篇中再做讲解。

map>

如果我们看过 map 的源码,就会发现其中有不少会引起 fatal 错误的地方,比如 mapaccess1(从 map 中读取 key 的函数)里面,如果发现正在写 map,则会有 fatal 错误。 (如果还没看过,可以跟着这篇 《go map 设计与实现》 看一下)

if h.flags&hashWriting != 0 {
    fatal("concurrent map read and map write")
}

map>

下面是一个实际使用中的例子:

var m = make(map[int]int)
// 往 map 写 key 的协程
go func() {
   // 往 map 写入数据
    for i := 0; i < 10000; i++ {
        m[i] = i
    }
}()
// 从 map 读取 key 的协程
go func() {
   // 从 map 读取数据
    for i := 10000; i > 0; i-- {
        _ = m[i]
    }
}()
// 等待两个协程执行完毕
time.Sleep(time.Second)

这会导致报错:

fatal error: concurrent map read and map write

这是因为我们同时对 map 进行读写,而 map 不支持并发读写,所以会报错。如果 map 允许并发读写,那么可能在我们使用的时候会有很多错乱的情况出现。 (具体如何错乱,我们可以对比多线程的场景思考一下,本文不展开了)。

使用>

对于 map 并发读写报错的问题,其中一种解决方案就是使用 sync.Mutex 来保证并发安全, 但是这样会导致我们在读写的时候,都需要加锁,这样就会导致性能的下降。

使用 sync.Mutex 来保证并发安全,上面的代码可以改成下面这样:

var m = make(map[int]int)
// 互斥锁
var mu sync.Mutex
// 写 map 的协程
go func() {
    for i := 0; i < 10000; i++ {
        mu.Lock() // 写 map,加互斥锁
        m[i] = i
        mu.Unlock()
    }
}()
// 读 map 的协程序
go func() {
    for i := 10000; i > 0; i-- {
        mu.Lock() // 读 map,加互斥锁
        _ = m[i]
        mu.Unlock()
    }
}()
time.Sleep(time.Second)

这样就不会报错了,但是性能会有所下降,因为我们在读写的时候都需要加锁。(如果需要更高性能,可以继续读下去,不要急着使用 sync.Mutex

sync.Mutex 的常见的用法是在结构体中嵌入 sync.Mutex,而不是定义独立的两个变量。

使用>

在上一小节中,我们使用了 sync.Mutex 来保证并发安全,但是在读和写的时候我们都需要加互斥锁。 这就意味着,就算多个协程进行并发读,也需要等待锁。 但是互斥锁的粒度太大了,但实际上,并发读是没有什么太大问题的,应该被允许才对,如果我们允许并发读,那么就可以提高性能。

当然 go 的开发者也考虑到了这一点,所以在 sync 包中提供了 sync.RWMutex,这个锁可以允许进行并发读,但是写的时候还是需要等待锁。 也就是说,一个协程在持有写锁的时候,其他协程是既不能读也不能写的,只能等待写锁释放才能进行读写。

使用 sync.RWMutex 来保证并发安全,我们可以改成下面这样:

var m = make(map[int]int)
// 读写锁(允许并发读,写的时候是互斥的)
var mu sync.RWMutex
// 写入 map 的协程
go func() {
    for i := 0; i < 10000; i++ {
        // 写入的时候需要加锁
        mu.Lock()
        m[i] = i
        mu.Unlock()
    }
}()
// 读取 map 的协程
go func() {
    for i := 10000; i > 0; i-- {
        // 读取的时候需要加锁,但是这个锁是读锁
        // 多个协程可以同时使用 RLock 而不需要等待
        mu.RLock()
        _ = m[i]
        mu.RUnlock()
    }
}()
// 另外一个读取 map 的协程
go func() {
    for i := 20000; i > 10000; i-- {
        // 读取的时候需要加锁,但是这个锁是读锁
        // 多个协程可以同时使用 RLock 而不需要等待
        mu.RLock()
        _ = m[i]
        mu.RUnlock()
    }
}()
time.Sleep(time.Second)

这样就不会报错了,而且性能也提高了,因为我们在读的时候,不需要等待锁。

说明:

    多个协程可以同时使用 RLock 而不需要等待,这是读锁。只有一个协程可以使用 Lock,这是写锁,有写锁的时候,其他协程不能读也不能写。持有写锁的协程,可以使用 Unlock 来释放锁。写锁释放之后,其他协程才能获取到锁(读锁或者写锁)。

    也就是说,使用 sync.RWMutex 的时候,读操作是可以并发执行的,但是写操作是互斥的。 这样一来,相比 sync.Mutex 来说等待锁的次数就少了,自然也就能获得更好的性能了。

    gin 框架里面就使用了 sync.RWMutex 来保证 Keys 读写操作的并发安全。

    有了读写锁为什么还要有>

    通过上面的内容,我们知道了,有下面两种方式可以保证并发安全:

      使用 sync.Mutex,但是这样的话,读写都是互斥的,性能不好。使用 sync.RWMutex,可以并发读,但是写的时候是互斥的,性能相对 sync.Mutex 要好一些。

      但是就算我们使用了 sync.RWMutex,也还是有一些锁的开销。那么我们能不能再优化一下呢?答案是可以的。那就是使用 sync.Map

      sync.Map 在锁的基础上做了进一步优化,在一些场景下使用原子操作来保证并发安全,性能更好。

      使用原子操作替代读锁

      但是就算使用>sync.RWMutex,读操作依然还有锁的开销,那么有没有更好的方式呢? 答案是有的,就是使用原子操作来替代读锁。

      举一个很常见的例子就是多个协程同时读取一个变量,然后对这个变量进行累加操作:

      var a int32
      var wg sync.WaitGroup
      wg.Add(2)
      go func() {
          for i := 0; i < 10000; i++ {
              a++
          }
          wg.Done()
      }()
      go func() {
          for i := 0; i < 10000; i++ {
              a++
          }
          wg.Done()
      }()
      wg.Wait()
      // a 期望结果应该是 20000才对。
      fmt.Println(a) // 实际:17089,而且每次都不一样
      

      这个例子中,我们期望的结果是 a 的值是 20000,但是实际上,每次运行的结果都不一样,而且都不会等于 20000。 其中很简单粗暴的一种解决方法是加锁,但是这样的话,性能就不好了,但是我们可以使用原子操作来解决这个问题:

      var a atomic.Int32
      var wg sync.WaitGroup
      wg.Add(2)
      go func() {
          for i := 0; i < 10000; i++ {
              a.Add(1)
          }
          wg.Done()
      }()
      go func() {
          for i := 0; i < 10000; i++ {
              a.Add(1)
          }
          wg.Done()
      }()
      wg.Wait()
      fmt.Println(a.Load()) // 20000
      

      锁跟原子操作的性能差多少?

      我们来看一下,使用锁和原子操作的性能差多少:

      func BenchmarkMutexAdd(b *testing.B) {
         var a int32
         var mu sync.Mutex
         for i := 0; i < b.N; i++ {
            mu.Lock()
            a++
            mu.Unlock()
         }
      }
      func BenchmarkAtomicAdd(b *testing.B) {
         var a atomic.Int32
         for i := 0; i < b.N; i++ {
            a.Add(1)
         }
      }
      

      结果:

      BenchmarkMutexAdd-12       100000000          10.07 ns/op
      BenchmarkAtomicAdd-12      205196968           5.847 ns/op

      我们可以看到,使用原子操作的性能比使用锁的性能要好一些。

      也许我们会觉得上面这个例子是写操作,那么读操作呢?我们来看一下:

      func BenchmarkMutex(b *testing.B) {
         var mu sync.RWMutex
         for i := 0; i < b.N; i++ {
            mu.RLock()
            mu.RUnlock()
         }
      }
      func BenchmarkAtomic(b *testing.B) {
         var a atomic.Int32
         for i := 0; i < b.N; i++ {
            _ = a.Load()
         }
      }
      

      结果:

      BenchmarkMutex-12      100000000          10.12 ns/op
      BenchmarkAtomic-12     1000000000          0.3133 ns/op

      我们可以看到,使用原子操作的性能比使用锁的性能要好很多。而且在 BenchmarkMutex 里面甚至还没有做读取数据的操作。

      sync.Map>

      sync.Map 里面相比 sync.RWMutex,性能更好的原因就是使用了原子操作。 在我们从 sync.Map 里面读取数据的时候,会先使用一个原子 Load 操作来读取 sync.Map 里面的 key(从 read 中读取)。 注意:这里拿到的是 key 的一份快照,我们对其进行读操作的时候也可以同时往 sync.Map 中写入新的 key,这是保证它高性能的一个很关键的设计(类似读写分离)。

      sync.Map 里面的 Load 方法里面就包含了上述的流程:

      // Load 方法从 sync.Map 里面读取数据。
      func (m *Map) Load(key any) (value any, ok bool) {
         // 先从只读 map 里面读取数据。
         // 这一步是不需要锁的,只有一个原子操作。
         read := m.loadReadOnly()
         e, ok := read.m[key]
         if !ok && read.amended { // 如果没有找到,并且 dirty 里面有一些 read 中没有的 key,那么就需要从 dirty 里面读取数据。
            // 这里才需要锁
            m.mu.Lock()
            read = m.loadReadOnly()
            e, ok = read.m[key]
            if !ok && read.amended {
               e, ok = m.dirty[key]
               m.missLocked()
            }
            m.mu.Unlock()
         }
         // key 不存在
         if !ok {
            return nil, false
         }
         // 使用原子操作读取
         return e.Load()
      }
      

      上面的代码我们可能还看不懂,但是没关系,这里我们只需要知道的是,从 sync.Map 读取数据的时候,会先做原子操作,如果没找到,再进行加锁操作,这样就减少了使用锁的频率了,自然也就可以获得更好的性能(但要注意的是并不是所有情况下都能获得更好的性能)。至于具体实现,在下一篇文章中会进行更加详细的分析。

      也就是说,sync.Map 之所以更快,是因为相比 RWMutex,进一步减少了锁的使用,而这也就是 sync.Map 存在的原因了

      sync.Map>

      现在我们知道了,sync.Map 里面是利用了原子操作来减少锁的使用。但是我们好像连 sync.Map 的一些基本操作都还不了解,现在就让我们再来看看 sync.Map 的基本用法。

      sync.Map 的使用还是挺简单的,map 中有的操作,在 sync.Map 都有,只不过区别是,在 sync.Map 中,所有的操作都需要通过调用其方法来进行。 sync.Map 里面几个常用的方法有(CRUD):

        Store:我们新增或者修改数据的时候,都可以使用 Store 方法。Load:读取数据的方法。Range:遍历数据的方法。Delete:删除数据的方法。
        var m sync.Map
        // 写入/修改
        m.Store("foo", 1)
        // 读取
        fmt.Println(m.Load("foo")) // 1 true
        // 遍历
        m.Range(func(key, value interface{}) bool {
            fmt.Println(key, value) // foo 1
            return true
        })
        // 删除
        m.Delete("foo")
        fmt.Println(m.Load("foo")) // nil false
        

        注意:在 sync.Map 中,keyvalue 都是 interface{} 类型的,也就是说,我们可以使用任意类型的 keyvalue。 而不像 map,只能存在一种类型的 keyvalue。从这个角度来看,它的类型类似于 map[any]any

        另外一个需要注意的是,Range 方法的参数是一个函数,这个函数如果返回 false,那么遍历就会停止。

        sync.Map>

        sync.Map 源码中,已经告诉了我们 sync.Map 的使用场景:

        The Map type is optimized for two common use cases: (1) when the entry for a given
        key is only ever written once but read many times, as in caches that only grow,
        or (2) when multiple goroutines read, write, and overwrite entries for disjoint
        sets of keys. In these two cases, use of a Map may significantly reduce lock
        contention compared to a Go map paired with a separate Mutex or RWMutex.

        翻译过来就是,Map 类型针对两种常见用例进行了优化:

          当给定 key 的条目只写入一次但读取多次时,如在只会增长的缓存中。(读多写少)当多个 goroutine 读取、写入和覆盖不相交的键集的条目。(不同 goroutine 操作不同的 key)

          在这两种情况下,与 Go map 与单独的 MutexRWMutex 配对相比,使用 sync.Map 可以显著减少锁竞争(很多时候只需要原子操作就可以)。

          总结

          普通的>map 不支持并发读写。

          有以下两种方式可以实现 map 的并发读写:

            使用 sync.Mutex 互斥锁。读和写的时候都使用互斥锁,性能相比 sync.RWMutex 会差一些。使用 sync.RWMutex 读写锁。读的锁是可以共享的,但是写锁是独占的。性能相比 sync.Mutex 会好一些。sync.Map 里面会先进行原子操作来读取 key,如果读取不到的时候,才会需要加锁。所以性能相比 sync.Mutexsync.RWMutex 会好一些。

            sync.Map 里面几个常用的方法有(CRUD):

              Store:我们新增或者修改数据的时候,都可以使用 Store 方法。Load:读取数据的方法。Range:遍历数据的方法。Delete:删除数据的方法。

              sync.Map 的使用场景,sync.Map 针对以下两种场景做了优化:

                key 只会写入一次,但是会被读取多次的场景。多个 goroutine 读取、写入和覆盖不相交的键集的条目。

                以上就是go sync.Map基本原理深入解析的详细内容,更多关于go sync.Map基本原理的资料请关注易采站长站其它相关文章!

                如有侵权,请发邮件到 [email protected]

相关文章

  • 使用Go基于WebSocket构建千万级视频直播弹幕系统的代码详解

    使用Go基于WebSocket构建千万级视频直播弹幕系统的代码详解

    (1)业务复杂度介绍 开门见山,假设一个直播间同时500W人在线,那么1秒钟1000条弹幕,那么弹幕系统的推送频率就是: 500W * 1000条/秒=50亿条/秒 ,想想B站2019跨年晚会那次弹幕系统得是
    2020-07-08
  • golang中import cycle not allowed解决的一种思路

    golang中import cycle not allowed解决的一种思路

    发现问题 项目中碰到了一些问题,使用了指针函数的思路来解决相应问题 在实际项目中,因为两个项目互相引了对方的一些方法,导致了循环引用的错误,原本可以使用http的请求来解
    2019-11-10
  • 从go语言中找&和*区别详解

    从go语言中找&和*区别详解

    *和的区别 : 是取地址符号 , 即取得某个变量的地址 , 如 ; a*是指针运算符 , 可以表示一个变量是指针类型 , 也可以表示一个指针变量所指向的存储单元 , 也就是这个地址所存储的值 . 从
    2020-06-23
  • Go语言中利用http发起Get和Post请求的方法示例

    Go语言中利用http发起Get和Post请求的方法示例

    关于 HTTP 协议 HTTP(即超文本传输协议)是现代网络中最常见和常用的协议之一,设计它的目的是保证客户机和服务器之间的通信。 HTTP 的工作方式是客户机与服务器之间的 “请求-应答
    2019-11-10
  • golang如何实现mapreduce单进程版本详解

    golang如何实现mapreduce单进程版本详解

    前言 MapReduce作为hadoop的编程框架,是工程师最常接触的部分,也是除去了网络环境和集群配 置之外对整个Job执行效率影响很大的部分,所以很有必要深入了解整个过程。元旦放假的第一天
    2019-11-10
  • Go打包二进制文件的实现

    Go打包二进制文件的实现

    背景 众所周知,go语言可打包成目标平台二进制文件是其一大优势,如此go项目在服务器不需要配置go环境和依赖就可跑起来。 操作 需求:打包部署到centos7 笔者打包环境:mac os 方法:
    2020-03-11
  • GO语言实现简单的目录复制功能

    GO语言实现简单的目录复制功能

    本文实例讲述了GO语言实现简单的目录复制功能。分享给大家供大家参考。具体实现方法如下: 创建一个独立的 goroutine 遍历文件,主进程负责写入数据。程序会复制空目录,也可以设
    2019-11-10
  • golang中定时器cpu使用率高的现象详析

    golang中定时器cpu使用率高的现象详析

    前言: 废话少说,上线一个用golang写的高频的任务派发系统,上线跑着很稳定,但有个缺点就是当没有任务的时候,cpu的消耗也在几个百分点。 平均值在3%左右的cpu使用率。你没有任务
    2019-11-10