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

在Go语言中,sync.Pool 是一个用于对象复用的机制,适合在高并发场景下减少GC压力。它能缓存临时对象,供后续重复使用,特别适用于频繁创建和销毁对象的场景,比如内存缓冲、临时结构体等。
基本用法与原理
sync.Pool 的对象是可被自动清理的,不保证长期存在,因此不能用于需要持久化状态的场景。每个P(Go调度中的处理器)都有本地池,减少锁竞争,提升性能。
通过 Get() 获取对象,若池中无可用对象,则调用 New 字段生成新对象;通过 Put() 将对象放回池中复用。
示例:复用字节缓冲
立即学习“go语言免费学习笔记(深入)”;
常见用途是复用 *bytes.Buffer,避免频繁分配小对象:
package main import ( "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 能有效提升程序性能,尤其在高并发服务中效果明显。


