sync.Pool用于对象复用以减少GC压力,适合高并发下临时对象的频繁创建与销毁;每个P有本地池降低锁竞争,Get()获取对象时若池为空则调用New生成,Put()将对象放回池中;使用前需重置状态防止数据污染,对象可能被随时清理,不适用于持久化场景。

在Go语言中,sync.Pool 是一个用于对象复用的机制,适合在高并发场景下减少GC压力。它能缓存临时对象,供后续重复使用,特别适用于频繁创建和销毁对象的场景,比如内存缓冲、临时结构体等。
基本用法与原理
sync.Pool 的对象是可被自动清理的,不保证长期存在,因此不能用于需要持久化状态的场景。每个P(Go调度中的处理器)都有本地池,减少锁竞争,提升性能。
通过 Get() 获取对象,若池中无可用对象,则调用 New 字段生成新对象;通过 Put() 将对象放回池中复用。
示例:复用字节缓冲
立即学习“go语言免费学习笔记(深入)”;
常见用途是复用 *bytes.Buffer,避免频繁分配小对象:
package mainimport ( "bytes" "fmt" "sync")var bufferPool = sync.Pool{ New: func() interface{} { return &bytes.Buffer{} },}func getBuffer() *bytes.Buffer { return bufferPool.Get().(*bytes.Buffer)}func putBuffer(buf *bytes.Buffer) { buf.Reset() // 清空内容,准备复用 bufferPool.Put(buf)}func main() { // 从池中获取 buffer buf := getBuffer() buf.WriteString("Hello, Pool!") fmt.Println(buf.String()) // 使用完放回池中 putBuffer(buf)}
在HTTP服务中复用对象
在Web服务中,每次请求可能需要临时对象。使用 sync.Pool 可显著降低内存分配次数。
示例:复用临时结构体
type RequestInfo struct { ID string Path string Data []byte}var infoPool = sync.Pool{ New: func() interface{} { return &RequestInfo{} },}func handleRequest(id, path string, data []byte) { // 获取对象 info := infoPool.Get().(*RequestInfo) info.ID = id info.Path = path info.Data = append(info.Data[:0], data...) // 复用切片底层数组 // 模拟处理 fmt.Printf("Handling: %s %sn", info.ID, info.Path) // 处理完成后重置并归还 info.ID = "" info.Path = "" info.Data = info.Data[:0] infoPool.Put(info)}
注意事项
sync.Pool 虽然好用,但需注意以下几点:
Pool 中的对象可能在任何时候被清除,不要依赖其长期存在Put 前应重置对象状态,防止数据污染New 字段是可选的,但如果未设置,Get 可能返回 nil适用于高频创建/销毁的临时对象,不适合持有大量内存或资源的对象(如文件句柄)
基本上就这些。正确使用 sync.Pool 能有效提升程序性能,尤其在高并发服务中效果明显。
以上就是Golang sync.Pool对象复用示例的详细内容,更多请关注创想鸟其它相关文章!
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/1409104.html
微信扫一扫
支付宝扫一扫