Go 面试 —— Go Map 的并发安全问题
面试官:你好,我们来聊下 Go 语言的 map 。首先,请聊下 Go 语言的 map 是不是并发安全的?
应试者:不是的。Go 语言的 map 不是并发安全的。如果在多个 goroutine 同时读写同一个 map 时,会出现竞态条件( race condition ),可能导致程序运行出错,甚至崩溃。
为了证明这一点,我可以展示一个并发不安全的示例:
package main
import (
"fmt"
"sync"
)
func main() {
m := make(map[int]int)
var wg sync.WaitGroup
for i := 0; i < 100; i++ {
wg.Add(1)
go func(n int) {
defer wg.Done()
m[n] = n
}(i)
}
wg.Wait()
fmt.Println("Map 的大小:", len(m))
}
这段代码可能会出现以下问题:
并发写入可能导致 map 数据损坏
可能会触发运行时 panic
最终的 map 大小可能不是预期的 100
面试官:OK 。那当我们需要在并发场景下使用 map 时,你有什么好的解决方案吗?
应试者:在 Go 语言中,主要有三种解决方案:
使用 sync.Mutex 互斥锁来保护 map
type SafeMap struct {
sync.Mutex
m map[int]int
}
func (sm *SafeMap) Set(key, value int) {
sm.Lock()
defer sm.Unlock()
sm.m[key] = value
}
func (sm *SafeMap) Get(key int) (int, bool) {
sm.Lock()
defer sm.Unlock()
val, exists := sm.m[key]
return val, exists
}
使用 sync.RWMutex,允许并发读,但写入互斥
type SafeMap struct {
sync.RWMutex
m map[int]int
}
func (sm *SafeMap) Get(key int) (int, bool) {
sm.RLock()
defer sm.RUnlock()
val, exists := sm.m[key]
return val, exists
}
使用 sync.Map,这是 Go 标准库提供的并发安全的 map 实现
var m sync.Map
// 存储
m.Store("key", "value")
// 读取
value, ok := m.Load("key")
// 删除
m.Delete("key")
面试官:能详细解释一下为什么普通的 map 不是并发安全的吗?这背后的机制是什么?
应试者:这涉及到 Go 语言 map 的底层实现。在 Go 的源码中( runtime/map.go ),map 的结构大致是这样的:
type hmap struct {
count int // 元素个数
flags uint8 // 状态标志
B uint8 // 桶的对数
noverflow uint16 // 溢出桶的近似数
hash0 uint32 // 哈希种子
buckets unsafe.Pointer // 桶数组
oldbuckets unsafe.Pointer // 旧桶数组,在扩容时使用
// ... 其他字段
}
并发不安全的根本原因在于:
map 的内部操作(如插入、删除)不是原子的
扩容过程中会修改桶的结构
多个 goroutine 同时操作会导致数据竞争
具体来说,一个简单的写入操作可能包含多个步骤:
计算 key 的哈希值
定位到具体的桶
在桶中找到空位
写入数据
这些步骤如果被并发执行,就会导致不可预期的结果。
面试官:sync.Map 是如何解决这些并发问题的?能详细介绍一下它的实现原理吗?
应试者:sync.Map 的核心设计是读写分离和优化的并发控制。我们可以看一下它的大致结构:
type Map struct {
mu Mutex
read atomic.Value // readOnly
dirty map[interface{}]*entry
misses int
}
type readOnly struct {
m map[interface{}]*entry
amended bool // 是否有新的数据在 dirty 中
}
它的主要优化策略包括:
双层存储:
read map:无锁读取
dirty map:需要加锁的可写 map
读优化:
优先从 read map 读取
使用原子操作 atomic.Value 保证读取的线程安全
写入机制:
先尝试在 read map 中更新
如果不成功,则加锁操作 dirty map
动态提升:
当 dirty map 被频繁访问时,会将其提升为 read map
实际的读写流程大致如下:
func (m *Map) Load(key interface{}) (value interface{}, ok bool) {
// 首先无锁读取 read map
read, _ := m.read.Load().(readOnly)
e, ok := read.m[key]
if !ok && read.amended {
// 如果 read map 没有,且有新数据,则加锁查询 dirty map
m.mu.Lock()
// 双检查,避免重复加锁
read, _ = m.read.Load().(readOnly)
e, ok = read.m[key]
if !ok && read.amended {
e, ok = m.dirty[key]
// 记录未命中次数,可能会晋升 dirty map
m.missLocked()
}
m.mu.Unlock()
}
// ... 返回结果
}
面试官:那么,sync.Map 是不是在所有并发场景下都是最佳选择?
应试者:不是的。sync.Map 有其特定的适用场景和局限性:
适用场景:
读操作明显多于写操作
key 是动态增长的
元素命中率较高
不适用场景:
写操作频繁
key 是有限且提前确定的
需要有序遍历 map
需要对 key 进行排序或自定义比较的场景
性能建议:
对于写多读少的场景,传统的 sync.Mutex + map 可能更高效
对于读写均衡的场景,可以考虑分片锁等自定义方案
面试官:最后,你能分享一个实际工作中处理并发 map 的最佳实践吗?
应试者:在高并发缓存场景,我曾使用分片锁方案来优化 map 的并发性能:
type ShardedMap struct {
shards []map[string]interface{}
locks []sync.RWMutex
shardCount int
}
func NewShardedMap(shardCount int) *ShardedMap {
sm := &ShardedMap{
shards: make([]map[string]interface{}, shardCount),
locks: make([]sync.RWMutex, shardCount),
shardCount: shardCount,
}
for i := 0; i < shardCount; i++ {
sm.shards[i] = make(map[string]interface{})
}
return sm
}
func (sm ShardedMap) getShard(key string) (map[string]interface{}, sync.RWMutex) {
hash := fnv32(key)
shardIndex := hash % uint32(sm.shardCount)
return sm.shards[shardIndex], &sm.locks[shardIndex]
}
func (sm *ShardedMap) Set(key string, value interface{}) {
shard, lock := sm.getShard(key)
lock.Lock()
defer lock.Unlock()
shard[key] = value
}
func fnv32(key string) uint32 {
hash := uint32(2166136261)
for i := 0; i < len(key); i++ {
hash *= 16777619
hash ^= uint32(key[i])
}
return hash
}
这种方案的优点:
降低锁的粒度
提高并发性能
可以根据业务动态调整分片数
面试官:很好,你对 map 的并发问题理解的相当充分。
应试者:非常感谢!
更多 Go 高质量内容👇: portal.yunosphere.com
欢迎关注我,经常分享有用的 Go 知识 / 面试 / 创业经历 / 其他编程知识 👇
公众号:GopherYes
B 站:YunFuns
知乎、掘金、头条号:YunFun
小红书号:986261983
很佩服楼主能有这样的行动力去做一件事,在这个时代就是要这样才能搞到钱,也是挺难的。
笑死,除了面试,很少会专研这个,你写业务的时候,写测试,不就测出来了吗?面试钻某个点的都是装的
#2 但是实际上问的这些问题本质都是对哈希表的优化,就算不是面试,有多线程大量读写共享最终也是这个方案,跟语言、面试也没啥关系
对啊,就是内存共享、争用、锁、一致性啊,业务都要考虑的,不要关注代码层,应该是先有思路再去专研,实现业务需求
好的,知道了,回去等通知吧。
是面试啊
对的哈哈
经典等通知😼
感谢感谢,喜欢研究技术,也做点自己喜欢的事,能有收入就更好了 😎
fastcache 也是分片锁的思路,切成 512 个 buckets ,进一步最主要就是针对 GC 做了优化,索引用 map[int]int noscan 来减小 GC 扫描开销,实际 key,value 放在一个自己手动 mmap 分配管理的 chunks ([][]bytes )里,跳过了 golang 自己的堆 gc 。这套思路上生产很多场景应该是够用了
或许没有一个编程语言能逃过八股文。
什么时候卖课
希望你官网的课程可以开放几节公开课,希望能看到你课程讲解的深度 和 你的表达能力。
感觉写得还不错,前两天另外一个人发 goroutine 还是什么的,被我评论区“省流”了。
虽然写得不错,但我读完感觉更期望有若干篇从软件设计角度研讨的文章——楼上也有人提到,这些代码背后其实就是运用不同策略应对不同场景的需求——那样的话想必能够提纲挈领,促使读者举一反三
这个我用过
在读取一段 ip 列表时 比如有 100 万个 ip 需要验证是否能 ping 通
但是不能顺序读取
需要随机从里面的列表读取
且不能漏 且需要并发每次读取 100 个不然一个个读取要几个月时间
且有超时条件
就需要用这个方法
但是也偶尔会触发 panic
如果不 panic 那处理的效率是 c#的数倍
#2 测出来算你烧高香。实际很多犄角旮旯的用错了测不出来,上线才会暴雷
八股文太多了,如果 op 能结合实际场景去分享,我觉得更吸引人一点。
面试官:不错,基础很扎实。能再谈一谈你对 Go 1.24 即将落地的 swiss table 的看法吗?
哈哈哈哈 接着问
#16 是的,线上出个并发的偶现问题是会搞死人的
感谢楼主分享。我写 go 才小半年,还是菜鸟一个,问我 map 的我都答不上。😂
在 Java 八股面前,这玩意和小儿科一样
面试官:好,那喜欢爸爸还是妈妈?
对,主要就是 GC 优化,自定义内存管理减少 Go 自己的 GC 。。。内存也更可控了。
哈哈哈哈哈,八股也算一种真实需求了😂
在卖了在卖了
听劝。改版下官网,最近出个公开课模块哈哈,其实前段时间搞了点免费课程 yunosphere.com ,最近也在一边更新一边重新规划公开的内容~ 欢迎关注 🤝 ,感谢宝贵的建议 🙏🙏
好的,后续会考虑搞一些业务实例来配合解读这样的,坚持研究跟更新 💪
🐂 🍺,这是大佬
后边会慢慢尝试从实例或者合理的场景出发聊一些内容,多谢建议🙏🙏 欢迎关注~ 我会尝试坚持产出嘿嘿
哈哈 有机会写写看~
前段时间还传出IBM要收购Sun的消息,当然,如果IBM收购Sun了,那么IBM真是活雷锋了。呵呵。 今天,Oralce正式宣布成功收购Sun,原文在这里。Oracle以每股9…
查了一些资料,说区块链超过 51%就有可能被篡改,但是目前的需求是要求 100%的技术上不能篡改,这个目前区块链技术可以做到吗或者其他技术也行?主要是合同相关的需求,所以必须要…
是这样的,我想做个标品产品的参数网站,例如显卡,固态硬盘,处理器这些。然后产品逻辑是,产品型号+产品 sku展示逻辑跟汽车之家或者是懂车帝这种网站的展现逻辑一样,一个型号下面有…