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

golang sync.Pool 指针数据覆盖问题

场景

1. sync.Pool设置

var stringPool = sync.Pool{New: func() any {return new([]string)},
}func NewString() *[]string {v := stringPool.Get().(*[]string)return v
}func PutString(s *[]string) {if s == nil {return}if cap(*s) > 2048 {s = nil} else {*s = (*s)[:0]stringPool.Put(s)}
}

2.使用sync.Pool

func Test_Pool(t *testing.T) {dataSlice1 := demoData()dataSlice2 := demoData()dataSlice2[1] = "test4"fmt.Printf("dataSlice1:%v %p,dataSlice2:%v %p\n", dataSlice1, dataSlice1, dataSlice2, dataSlice2)
}func demoData() []string {strsPtr := NewString()strs := *strsPtrdefer func() {*strsPtr = strsPutString(strsPtr)}()strs = append(strs, "test1", "test2")return strs
}

打印结果:dataSlice1:[test1 test4] 0xc0000a6400,dataSlice2:[test1 test4] 0xc0000a6400

可以看到两个slice地址相同,内部使用同一个地址的数组,导致两次获取的数据互相影响

3.解决方法1

func Test_Pool(t *testing.T) {dataSlice1 := demoData()dataSlice2 := demoData()dataSlice2[1] = "test4"fmt.Printf("dataSlice1:%v %p,dataSlice2:%v %p\n", dataSlice1, dataSlice1, dataSlice2, dataSlice2)
}func demoData() []string {strsPtr := NewString()strs := *strsPtrdefer func() {*strsPtr = strsPutString(strsPtr)}()strs = append(strs, "test1", "test2")// 深复制var items = make([]string, len(strs))copy(items, strs)return items
}

使用深复制,在put回sync.Pool中之前把数据复制返回,但这样资源池失去了意义,获取到资源后有进行了一次内存的申请

4.解决方法2

我们看下golang语言源码怎么解决的

参考 go/src/fmt/print.go 302行 Fprintln方法

func Fprintln(w io.Writer, a ...any) (n int, err error) {p := newPrinter()p.doPrintln(a)n, err = w.Write(p.buf)p.free()return
}

可以看到306行有p.free()代码,newPrinter()和free()之间进行数据处理,数据处理完成之后再把资源返回给sync.Pool

总结:不是任何场景都适合用sync.Pool,需要关注并发情况下资源池中数据同步修改影响的问题。

http://www.lryc.cn/news/317591.html

相关文章:

  • VUE+内置iframe传值失效问题解决
  • Day31:安全开发-JS应用WebPack打包器第三方库JQuery安装使用安全检测
  • Go Zero微服务个人探究之路(十六)回顾api服务和rpc服务的本质
  • 基于YOLOv8/YOLOv7/YOLOv6/YOLOv5的夜间车辆检测系统(深度学习代码+UI界面+训练数据集)
  • Spring体系架构
  • 【PLC】现场总线和工业以太网汇总
  • 【吊打面试官系列】Java虚拟机JVM篇 - 关于JVM分析
  • Mysql锁与MVCC
  • rancher是什么
  • 阿里云服务器安全狗免费使用多引擎智能查杀引擎
  • 使用rust实现九九乘法表
  • 突破编程_C++_设计模式(简单工厂模式)
  • C语言——快速排序
  • FP独立站获客秘籍大揭秘:简单高效,一看就会!
  • 英伟达tx2光驱烧录功能支持
  • 关于stm32(CubeMX+HAL库)的掉电检测以及flash读写
  • Elastic script_score的使用
  • 【Spring Boot 3】获取已注入的Bean
  • C# 对于点位置的判断
  • 最新CLion + STM32 + CubeMX 开发环境搭建
  • 【Python3】观察者模式
  • HTML5 Web Worker之性能优化
  • 应对恶意IP攻击的有效方法
  • 如何使用“Docker registry创建本地仓库,在服务器之间进行文件push和pull”?
  • Rocky Linux - Primavera P6 EPPM 安装及分享
  • API 管理调研
  • 在centOS服务器安装docker,并使用docker配置nacos
  • JVM运行时数据区概述以及分别存放的内容
  • 数据体系规范化
  • 从政府工作报告探计算机行业发展