前言
- sync.Map的核心实现 - 两个map,一个用于写,另一个用于读,这样的设计思想可以类比缓存与数据库
- sync.Map的局限性 - 如果写远高于读,dirty->readOnly 这个类似于 刷数据 的频率就比较高,不如直接用 mutex + map 的组合
- sync.Map的设计思想 - 保证高频读的无锁结构、空间换时间
- 线程安全,多用于读远高于写的场景,多核
代码
package main import ( "fmt" "sync" ) func syncMap() { var m sync.Map m.Store("a", 1) //存 fmt.Println(m.Load("a")) //取 // Tip: LoadOrStore 有就加载值,没有就保存值 fmt.Println(m.LoadOrStore("a", 1)) m.Delete("a") //删 fmt.Println(m.LoadOrStore("a", 1)) fmt.Println(m.LoadOrStore("b", 2)) // Tip: 遍历 m.Range(func(key, value interface{}) bool { fmt.Println(key, value) return true }) }
描述
type Map struct { mu Mutex read atomic.Value // readOnly dirty map[interface{}]*entry misses int } type readOnly struct { m map[interface{}]*entry amended bool // true if the dirty map contains some key not in m. }
sync.map内部有两个map,一个是dirty map[interface{}]*entry,一个是只读的map,新数据放到dirty,到达一定的数据量后,将dirty的数据放到只读的map里面,dirty里面放着比较新的数据,并且操作dirty是需要加锁的,而只读的map操作它无需加锁,到了misses的次数就是dirty到read的转换