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

news/2024/11/15 6:53:36/

场景

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.ppmy.cn/news/1381968.html

相关文章

TortoiseSVN 报错:The server unexpectedly closed the connetion

前言 CentOS7Linux 安装subversionmod_dav_svn,搭建subversion(svn)服务器 The server unexpectedly closed the connetion 解决办法 重启Apache服务 shell> systemctl restart httpd

ajax框架格式,每个属性的作用

AJAX(Asynchronous JavaScript and XML)框架是一种用于创建异步Web应用程序的技术。在AJAX框架中,通常使用JavaScript来发送和接收HTTP请求,从而在不重新加载整个页面的情况下更新页面的部分内容。虽然AJAX不是特定的框架&#xf…

每天学习一个Linux命令之head

每天学习一个Linux命令之head Linux命令行中有很多实用的命令,今天我们要介绍的是head命令。head命令用于显示文件的开头部分,默认情况下显示文件的前10行。 基本语法 head [选项] [文件]命令选项 head命令有一些可用的选项,我们将一一介…

FPGA - 单总线协议(one-wire)

1,简介 单总线(one-wire)是美国 DALLAS 公司推出的外围串行扩展总线技术,与 SPI、I2C 等串行数据通信方式不同,它采用单根信号线,既传输时钟又传输数据,而且数据传输是双向的。它具有节省 I/O口…

安卓基础面试题

自定义view Android自定义View-CSDN博客 view和viewgroup View和ViewGroup的区别- view的事件分发 事件分发详解---历史最容易理解 组件化 Android-组件化开发 什么是ANR Android ANR详解-CSDN博客 Android性能优化 Android 优化-CSDN博客 Aroute 原理 Arouter框架原理…

计算机缺失iutils.dll怎么办,分享5种靠谱的解决方法

​在计算机系统运行过程中,如果发现无法找到或缺失iutils.dll文件,可能会引发一系列的问题与故障。首先,由于iutils.dll是系统中一个重要的动态链接库文件,它的主要功能可能涉及到系统核心服务、应用程序支持或者特定功能模块的运…

【Unity知识点详解】Button点击事件拓展,单击、双击、长按实现

Button拓展 今天来聊一下关于Button的事件拓展,这里只是拿Button来举例,Unity中其他的UI组件如Toggle、Slider等都也适用。 我们知道在Button中我们可以通过onClick的方式来添加点击事件,但在游戏开发过程中我们往往对Button有着更多的功能需…

备战蓝桥杯Day25 - 二叉搜索树查询和删除操作

一、查询 递归查询 寻找的值比根节点大&#xff0c;遍历右子树&#xff1b; 寻找的值比根节点小&#xff0c;遍历左子树。 def qurey(self, node, val):if not node: # 没有节点&#xff0c;返回空return Noneif node.data < val:return self.qurey(node.rchild, val)el…