当前位置: 首页 > news >正文

《Go小技巧易错点100例》第三十二篇

本期分享:

1.sync.Map的原理和使用方式

2.实现有序的Map

sync.Map的原理和使用方式

sync.Map的底层结构是通过读写分离无锁读设计实现高并发安全:

1)双存储结构

包含原子化的 read(只读缓存,无锁快速访问)和加锁的 dirty(写入缓冲区)

2)读优先

读取时先尝试无锁访问 read,未命中时加锁访问 dirty 并记录未命中次数

3)动态升级

当未命中次数超过 dirty 长度时,将 dirty 原子替换为新的 read

4)延迟删除

删除操作仅标记数据状态(expunged),实际清理在 dirty 升级时批量处理

5)值原子化

通过 entry 指针的原子操作实现值更新的无锁化,适用于读多写少的高并发场景。

请在此添加图片描述

部分源码:

type Map struct {mu     sync.Mutex       // 保护 dirty 操作read   atomic.Value     // 只读缓存(atomic 访问)dirty  map[interface{}]*entry  // 写入缓冲区misses int              // read 未命中计数器
}type entry struct {p unsafe.Pointer  // 可能的状态:nil, expunged, 有效指针
}

Go 语言标准库中的 sync.map 专为以下场景优化:

  • 读多写少(98% 读操作)
  • 动态键空间(频繁创建/删除键)
  • 需要保证并发安全

性能对比测试: 测试场景为4核CPU环境下并发读写

实现方式100万次读/写 (ns/op)内存占用 (MB)
map+sync.RWMutex42032
sync.Map8528

实现有序的map

在Go语言中,标准库的map是无序的,但可以通过组合数据结构实现有序映射。以下是几种常见实现方案,根据需求选择最适合的方式:

方案一:维护插入顺序(链表法)
package mainimport"fmt"type OrderedMap struct {items map[interface{}]interface{}order []interface{}
}func NewOrderedMap() *OrderedMap {return &OrderedMap{items: make(map[interface{}]interface{}),order: make([]interface{}, 0),}
}func (m *OrderedMap) Set(key, value interface{}) {if _, exists := m.items[key]; !exists {m.order = append(m.order, key)}m.items[key] = value
}func (m *OrderedMap) Get(key interface{}) (interface{}, bool) {val, exists := m.items[key]return val, exists
}func (m *OrderedMap) Delete(key interface{}) {delete(m.items, key)// 重建顺序切片(简单实现,实际可用更高效方式)newOrder := make([]interface{}, 0, len(m.order)-1)for _, k := range m.order {if k != key {newOrder = append(newOrder, k)}}m.order = newOrder
}func (m *OrderedMap) Iterate() {for _, key := range m.order {fmt.Printf("%v: %v\n", key, m.items[key])}
}
方案二:排序映射(使用sort包)
package mainimport ("fmt""sort"
)type SortedMap struct {keys  []intitems map[int]string
}func NewSortedMap() *SortedMap {return &SortedMap{keys:  make([]int, 0),items: make(map[int]string),}
}func (m *SortedMap) Set(key int, value string) {if _, exists := m.items[key]; !exists {m.keys = append(m.keys, key)sort.Ints(m.keys) // 保持有序}m.items[key] = value
}func (m *SortedMap) Get(key int) (string, bool) {val, exists := m.items[key]return val, exists
}func (m *SortedMap) Iterate() {for _, key := range m.keys {fmt.Printf("%d: %s\n", key, m.items[key])}
}
方案三:使用第三方库(推荐)
import "github.com/emirpasic/gods/maps/treemap"func main() {// 自然排序m := treemap.NewWithIntComparator()m.Put(1, "one")m.Put(3, "three")m.Put(2, "two")// 迭代器it := m.Iterator()for it.Next() {fmt.Printf("%d: %s\n", it.Key(), it.Value())}// 反向迭代rit := m.ReverseIterator()for rit.Next() {fmt.Printf("%d: %s\n", rit.Key(), rit.Value())}
}

本篇结束~

欢迎关注我

相关文章:

  • 实战项目1(02)
  • 《AI大模型应知应会100篇》第55篇:大模型本地开发环境搭建
  • NB-IoT嵌入式产品开发有哪些坑?
  • TIME - MoE 模型代码 5——Time-MoE-main/time_moe/utils/log_util.py
  • Scrapy 核心组件解析:Request Response 的深度应用与实战
  • Web 性能优化四:资源体积压缩与加载策略详解:JS / CSS / 图片 / 字体怎么减负?
  • 风扇接口
  • 0基础 | L298N电机驱动模块 | 使用指南
  • C语言常见的文件操作函数总结
  • QSS样式表的选择器
  • iVX 图形化编程平台:结合 AI 原生开发的革新与实践
  • 模块化编程
  • 【问题】Watt加速github访问速度:好用[特殊字符]
  • ACM模式手动构建二叉树
  • 精读计算机体系结构基础 第三章 特权指令系统
  • 使用 SHAP 进行特征交互检测:揭示变量之间的复杂依赖关系
  • 豆包:国内 web 辅助开发的领头羊
  • 以党建网为例,深入分析IT技术栈,实战经验
  • 基于多层权重博弈与广播机制的仿生类脑 AI 决策框架
  • 文件(分片)并行上传时计算总的上传进度
  • 云南大理铁路枢纽工程建设取得两大进展,预计明年建成
  • 马上评丨75万采购300元设备,仅仅终止采购还不够
  • 中共中央、国务院印发《生态环境保护督察工作条例》
  • OpenAI与微软正谈判修改合作条款,以推进未来IPO
  • 5月12日-14日,上海小升初民办初中进行网上报名
  • A股三大股指集体高开