GO:sync.Map

news/2025/1/10 2:19:47 标签: golang, 开发语言, 后端

sync.Map 是 Go 语言 sync 包中提供的一个内置的并发安全的 map 类型。它在设计上考虑了高并发场景,尽量避免加锁操作从而提升读写性能。

这里是一段关于sync.map使用的简单记录

package main

import (
    "fmt"
    "sync"
)

func main() {
    var m sync.Map
    // 存储
    m.Store("key1", "value1")
    m.Store("key2", 2)
    // 读取
    value, ok := m.Load("key1")
    if ok {
        fmt.Println("Value:", value)
    }
    // 删除
    m.Delete("key1")
    value, ok = m.Load("key1")
    if ok {
        fmt.Println("Value:", value)
    } else {
        fmt.Println("Key not found")
    }
}

sync.map的底层数据结构 最主要的构成两个部分 

1 read  无锁map  存储了部分写入 Map 的内容,用来加速读操作。

2 dirty  加锁读写map 存储了全量内容,需要加锁才能读写数据。

type Map struct {
    mu Mutex
    read atomic.Pointer[readOnly] // 无锁读map
    dirty map[any]*entry // 加锁读写map
    misses int
}

// readOnly is an immutable struct stored atomically in the Map.read field.
type readOnly struct {
    m       map[any]*entry
    amended bool // true if the dirty map contains some key not in m.
}

当有 key-value 值写入时:

如果这个 key 在 read 中不存在,接下来就要做新增操作,它会加锁写入 dirty map 中,并且将 amended 标记设置为 true。而 amended 标记用于表示 dirty 中是否有不在 read 中的 key-value 值。

如果这个 key 在 read 中存在,则会进行更新操作,由于 read map 和 dirty map 里面存储的值是 entry 类型的指针,且 entry 类型的成员变量也是 atomic.Pointer 类型

因此在更新时可以直接用 CAS 无锁操作替换指针 p 指向的变量,而无需做加锁操作。

当读取 key 对应的值时:

会先从 read 中读取,当 read 中读不到,并且 amended 为 true 时,则会加锁从 dirty map 中读。这里可能导致从 sync.Map 读取的性能劣化,因为它既要从 read 中读一遍,又要加锁从 dirty map 中读一遍。 

同时,每次 read 读不到,从 dirty map 中读时,它会调用 missLocked 方法,这个方法用于将 map 的 misses 字段加 1,misses 字段用于表示 read 读未命中次数,如果 misses 值比较大,说明 read map 的数据可能比 dirty map 少了很多。为了提升读性能,missLocked 方法里会将 dirty map 变成新的 read map,代码如下。

缺点:

sync.Map 是通过两个 map 来实现读写分离,从而达到高性能读的目的。不过它存在下面几个缺点。

1  由于有两个 map,因此占用内存会比较高。

2  更适用于读多写少的场景,当由于写比较多或者本地缓存没有全量数据时,会导致读 map 经常读不到数据,而需要加锁再读一次,从而导致读性能退化。

3  当数据量比较大时,如果写入触发读 map 向写 map 拷贝,会导致较大的性能开销。

所以在大规模数据缓存时 我们最好选用 分段锁 

 


http://www.niftyadmin.cn/n/5818139.html

相关文章

api开发如何在代码中使用京东商品详情接口的参数?

选择编程语言和相关工具 以 Python 为例,你可以使用requests库来发送 HTTP 请求获取接口数据。如果是 Java,可以使用OkHttp等库。 Python 示例 假设你已经安装了requests库,以下是一个简单的代码示例来获取和使用京东商品详情接口参数&#…

卷积神经网络 (CNN, Convolutional Neural Network) 算法详解与PyTorch实现

卷积神经网络 (CNN, Convolutional Neural Network) 算法详解与PyTorch实现 目录 卷积神经网络 (CNN, Convolutional Neural Network) 算法详解与PyTorch实现1. 卷积神经网络 (CNN) 算法概述1.1 图像处理1.2 CNN的优势2. CNN的核心技术2.1 卷积层2.2 池化层2.3 全连接层2.4 激活…

Solidity合约编写(五)

解决问题 编写 FundMe.sol 一个众筹合约,允许用户向合约转账 ETH,并记录每个地址的转账金额。同时,合约还要求每次转账至少为 1 ETH,否则交易失败。最后,合约管理员可以提取资金,并使用 call 函数发送 ETH…

golang中的字符串,字符串驻留 Intern,unique包

Go1.23 Go字符串 Go语言中的字符串是一个不可变的字节序列,这意味着一旦字符串被创建,其内容就不能被修改(尽管可以通过切片、拼接等方式生成新的字符串)。这一设计选择不仅简化了字符串的处理逻辑,还提高了程序的并…

Netty中用了哪些设计模式?

大家好,我是锋哥。今天分享关于【Netty中用了哪些设计模式?】面试题。希望对大家有帮助; Netty中用了哪些设计模式? 1000道 互联网大厂Java工程师 精选面试题-Java资源分享网 Netty 是一个高性能的网络通信框架,广泛…

【25考研】川大计算机复试情况,重点是啥?怎么准备?

24年进入复试的同学中,有10位同学的复试成绩为0分。具体是个人原因还是校方原因,还尚不明确。但是C哥提醒,一定要认真复习!复试完后不要跟任何人讨论有关复试的题目及细节! 一、复试内容 四川大学复试内容较多&#xf…

【C++习题】20. 两个数组的交集

题目:349. 两个数组的交集 - 力扣(LeetCode) 链接🔗:349. 两个数组的交集 - 力扣(LeetCode) 题目: 代码: class Solution { public:// 函数功能:求两个数组…

Android 修改DialogFragment的大小

如题 在开发中自定义dialog 为了正确使用dialog 有效的生命周期观察 可以使用dialogFragment 如果在布局中设置的大小无效 可以在dialog开始之前 使用系统布局对属性进行修改 Overridepublic void onStart() {super.onStart();if (getDialog() ! null && getDialog().…