Golang sync.Pool对象复用示例

P粉602998670

发布时间：2025-09-28 22:29:01

894人浏览过

来源于php中文网

原创

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

golang sync.pool对象复用示例

在Go语言中，sync.Pool 是一个用于对象复用的机制，适合在高并发场景下减少GC压力。它能缓存临时对象，供后续重复使用，特别适用于频繁创建和销毁对象的场景，比如内存缓冲、临时结构体等。

基本用法与原理

sync.Pool 的对象是可被自动清理的，不保证长期存在，因此不能用于需要持久化状态的场景。每个P（Go调度中的处理器）都有本地池，减少锁竞争，提升性能。

通过 Get() 获取对象，若池中无可用对象，则调用 New 字段生成新对象；通过 Put() 将对象放回池中复用。

示例：复用字节缓冲

立即学习“go语言免费学习笔记（深入）”；

常见用途是复用 *bytes.Buffer，避免频繁分配小对象：

SCA介绍及应用实例中文WORD版

本文档主要讲述的是SCA介绍及应用实例；SCA（Service Component Architecture）是针对SOA提出的一套服务体系构建框架协议，内部既融合了IOC的思想，同时又把面向对象的复用由代码复用上升到了业务模块组件复用，同时将服务接口，实现，部署，调用完全分离，通过配置的形式灵活的组装，绑定。希望本文档会给有需要的朋友带来帮助；感兴趣的朋友可以过来看看

下载

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 %s\n", info.ID, info.Path)

    // 处理完成后重置并归还
    info.ID = ""
    info.Path = ""
    info.Data = info.Data[:0]
    infoPool.Put(info)
}