sync.Pool-CFANZ编程社区

1.介绍

1.1sync.Pool是什么

sync.pool是Go1.3发布的一个特性，它是一个临时对象存储池，程序员使用时不能对Pool中的元素个数做假定

1.2为什么使用sync.Pool

1.保存和复用临时对象

2.减少内存分配

3.降低GC压力

1.3sync.Pool方法有哪些

//初始化Pool实例
New func() interface{} 

//申请对象
//Get方法会返回Pool中已经存在的对象，如果不存在，就调用New初始化
func (p *Pool) Get() interface{}

//释放对象
//使用完对象后，要放回赤字中。注意：池子中的对象什么时候真正释放是不受外界控制的。
func (p *Pool) Put(x interface{})

1.4思考？

1.为什么使用Pool，而不是在运行的时候直接实例话对象呢？

2.sync.Pool是并发安全的吗？

3.为什么sync.Pool不适合用于像socket长链接活数据库连接池？

2.案例

package main

import (
    "fmt"
    "sync"
    "sync/atomic"
)

// 用来统计实例真正创建的次数
var numCalcsCreated int32

// 创建实例的函数
func createBuffer() interface{} {
    // 这里要注意下，非常重要的一点。这里必须使用原子加，不然有并发问题；
    atomic.AddInt32(&numCalcsCreated, 1)
    buffer := make([]int, 0, 100)
    return &buffer
}

func main() {
    // 创建实例
    bufferPool := &sync.Pool{
        New: createBuffer,
    }

    // 多 goroutine 并发测试
    numWorkers := 30
    var wg sync.WaitGroup
    wg.Add(numWorkers)

    for i := 0; i < numWorkers; i++ {
        routineNum := i
        go func() {
            defer wg.Done()
            // 申请一个 buffer 实例
            buffer := bufferPool.Get()
            li := buffer.(*[]int)
            *li = append(*li, routineNum, routineNum+1, routineNum+2)
            fmt.Println(li)

            // 释放一个 buffer 实例
            defer func() {
                //使用完了恢复原样
                *li = []int{}
                bufferPool.Put(buffer)
            }()
        }()
    }
    wg.Wait()
    fmt.Printf("%d buffer objects were created.\n", numCalcsCreated)
}