前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >Golang sync.Pool 简介与用法

Golang sync.Pool 简介与用法

作者头像
恋喵大鲤鱼
发布2019-08-01 10:52:22
2.5K0
发布2019-08-01 10:52:22
举报
文章被收录于专栏:C/C++基础

Pool 是可伸缩、并发安全的临时对象池,用来存放已经分配但暂时不用的临时对象,通过对象重用机制,缓解 GC 压力,提高程序性能。

一个比较好的例子是 fmt 包,fmt 包总是需要使用一些 []byte 之类的对象,Golang 建立了一个临时对象池,存放着这些对象,如果需要使用一个 []byte,就去 Pool 中取,如果拿不到就分配一个。这比起不停生成新的[]byte,用完了再等待 GC 回收要高效得多。

注意,sync.Pool 是一个临时的对象池,适用于储存一些会在 goroutine 间共享的临时对象,其中保存的任何项都可能随时不做通知地释放掉,所以不适合用于存放诸如 socket 长连接或数据库连接的对象。

代码语言:javascript
复制
type Pool struct {

        // New optionally specifies a function to generate
        // a value when Get would otherwise return nil.
        // It may not be changed concurrently with calls to Get.
        New func() interface{}
        // contains filtered or unexported fields
}

//从 Pool 中获取元素,元素数量 -1,当 Pool 中没有元素时,会调用 New 生成元素,新元素不会放入 Pool 中,若 New 未定义,则返回 nil
func (p *Pool) Get() interface{}

//往 Pool 中添加元素 x
func (p *Pool) Put(x interface{})

代码示例

代码语言:javascript
复制
package main

import (
    "bytes"
    "io"
    "os"
    "sync"
    "time"
)

var bufPool = sync.Pool {
    New: func() interface{} {
        return new(bytes.Buffer)
    },
}

func PoolTest(w io.Writer, key, val string) {
    b, _ := bufPool.Get().(*bytes.Buffer)
    b.Reset()
    b.WriteString(time.Now().UTC().Format("2006-01-02 15:04:05"))
    b.WriteByte('|')
    b.WriteString(key)
    b.WriteByte('=')
    b.WriteString(val)
    w.Write(b.Bytes())
	w.Write([]byte("\n"))
    bufPool.Put(b)
}

func main() {
    PoolTest(os.Stdout, "dablelv", "monkey")
}

编译运行结果:

代码语言:javascript
复制
2019-07-12 12:11:47|dablelv=monkey

参考文章

[1] Package sync.Pool [2] How did I improve latency by 700% using sync.Pool [3] 深入Golang之sync.Pool详解

本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2019年07月12日,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 参考文章
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档