golang sync.Pool包的使用和一些注意地方

package main;

import (
	"sync"
	"fmt"
	"net"
	"runtime"
)

//sync.Pool是一个可以存或取的临时对象集合
//sync.Pool可以安全被多个线程同时使用,保证线程安全
//注意、注意、注意,sync.Pool中保存的任何项都可能随时不做通知的释放掉,所以不适合用于像socket长连接或数据库连接池。
//sync.Pool主要用途是增加临时对象的重用率,减少GC负担。

func testTcpConnPool() {
	sp2 := sync.Pool{
		New: func() interface{} {
			conn, err := net.Dial("tcp", ":80");
			if err != nil {
				return nil;
			}
			return conn;
		},
	};
	buf := make([]byte, 1024);
	//获取对象
	conn := sp2.Get().(net.Conn);
	//使用对象
	conn.Write([]byte("GET / HTTP/1.1 \r\n\r\n"));
	n, _ := conn.Read(buf);
	fmt.Println("conn read : ", string(buf[:n]));
	//打印conn的地址
	fmt.Println(conn);
	//把对象放回池中
	sp2.Put(conn);
	//我们人为的进行一次垃圾回收
	runtime.GC();
	//再次获取池中的对象
	conn2 := sp2.Get().(net.Conn);
	//这时发现conn2的地址与上面的conn的地址不一样了
	//说明池中我们之前放回的对象被全部清除了,显然这并不是我们想看到的
	//所以sync.Pool不适合用于scoket长连接或数据库连接池
	fmt.Println(conn2);
}

func main() {
	//我们创建一个Pool,并实现New()函数
	sp := sync.Pool{
		//New()函数的作用是当我们从Pool中Get()对象时,如果Pool为空,则先通过New创建一个对象,插入Pool中,然后返回对象。
		New: func() interface{} {
			return make([]int, 16);
		},
	};
	item := sp.Get();
	//打印可以看到,我们通过New返回的大小为16的[]int
	fmt.Println("item : ", item);

	//然后我们对item进行操作
	//New()返回的是interface{},我们需要通过类型断言来转换
	for i := 0; i < len(item.([]int)); i++ {
		item.([]int)[i] = i;
	}
	fmt.Println("item : ", item);

	//使用完后,我们把item放回池中,让对象可以重用
	sp.Put(item);

	//再次从池中获取对象
	item2 := sp.Get();
	//注意这里获取的对象就是上面我们放回池中的对象
	fmt.Println("item2 : ", item2);
	//我们再次获取对象
	item3 := sp.Get();
	//因为池中的对象已经没有了,所以又重新通过New()创建一个新对象,放入池中,然后返回
	//所以item3是大小为16的空[]int
	fmt.Println("item3 : ", item3);

	//测试sync.Pool保存socket长连接池
	testTcpConnPool();
}

时间: 2024-08-27 03:55:29

golang sync.Pool包的使用和一些注意地方的相关文章

深入Golang之sync.Pool详解

我们通常用golang来构建高并发场景下的应用,但是由于golang内建的GC机制会影响应用的性能,为了减少GC,golang提供了对象重用的机制,也就是sync.Pool对象池. sync.Pool是可伸缩的,并发安全的.其大小仅受限于内存的大小,可以被看作是一个存放可重用对象的值的容器. 设计的目的是存放已经分配的但是暂时不用的对象,在需要用到的时候直接从pool中取. 任何存放区其中的值可以在任何时候被删除而不通知,在高负载下可以动态的扩容,在不活跃时对象池会收缩. sync.Pool首先

[Go] sync.Pool 的实现原理 和 适用场景

摘录一: Go 1.3 的 sync 包中加入一个新特性:Pool. 官方文档可以看这里 http://golang.org/pkg/sync/#Pool 这个类设计的目的是用来保存和复用临时对象,以减少内存分配,降低CG压力. type Pool func (p *Pool) Get() interface{} func (p *Pool) Put(x interface{}) New func() interface{} Get 返回 Pool 中的任意一个对象. 如果 Pool 为空,则调

go语言学习--go的临时对象池--sync.Pool

一个sync.Pool对象就是一组临时对象的集合.Pool是协程安全的. Pool用于存储那些被分配了但是没有被使用,而未来可能会使用的值,以减小垃圾回收的压力.一个比较好的例子是fmt包,fmt包总是需要使用一些[]byte之类的对象,golang建立了一个临时对象池,存放着这些对象,如果需要使用一个[]byte,就去Pool里面拿,如果拿不到就分配一份. 这比起不停生成新的[]byte,用完了再等待gc回收来要高效得多. type buffer []byte // pp是用于存储printe

sync.Pool 的实现原理 和 适用场景

原文链接 摘录一: Go 1.3 的 sync 包中加入一个新特性:Pool. 官方文档可以看这里 http://golang.org/pkg/sync/#Pool 这个类设计的目的是用来保存和复用临时对象,以减少内存分配,降低CG压力. 1 2 3 4 type Pool      func (p *Pool) Get() interface{}      func (p *Pool) Put(x interface{})      New func() interface{} Get 返回

Go36-33-临时对象池(sync.Pool)

临时对象池(sync.Pool) sync.Pool是Go语言标准库中的一个同步工具. 介绍 sync.Pool类型可以被称为临时对象池,它的值可以被用来存储临时的对象.它属于结构体类型,在它的值被真正使用之后,就应该再被复制了. 临时对象,就是不需要持久使用的某一类值.这类值对于程序来说可有可无,但如果有的话明显更好.它们的创建和销毁可以在任何时候发生,并且完全不会影响到程序功能.同时,它们也应该是无需被区分的,其中的任何一个值都可以代替另一个.如果某类值完全符合上述条件,就可以把它们存储到临

Golang官方log包详解

Golang官方log包详解 以下全是代码, 详解在注释中, 请从头到尾看 // Copyright 2009 The Go Authors. All rights reserved. // Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. // Package log implements a simple logging package. I

golang的io包

package io import "io" io包提供了对I/O原语的基本接口.本包的基本任务是包装这些原语已有的实现(如os包里的原语),使之成为共享的公共接口,这些公共接口抽象出了泛用的函数并附加了一些相关的原语的操作. 因为这些接口和原语是对底层实现完全不同的低水平操作的包装,除非得到其它方面的通知,客户端不应假设它们是并发执行安全的. Index Variables type Reader type Writer type Closer type Seeker type Re

使用golang的pprof包对程序进行性能分析

程序经常出现OOM错误,然后关键字"go pprof"搜到文章<Go程序性能分析pprof>,该文章第二步说运行程序后会生成profile文件,但是编译运行后发现生成的profile文件大小一直为0,然后关键字"go pprof profile is empty"搜到文章<Golang pprof heap profile is empty>,该文章说在运行程序前添加环境变量GODEBUG="memprofilerate=1&quo

Golang Gin 项目包依赖管理 godep 使用

Golang Gin 项目包依赖管理 godep 使用 标签(空格分隔): Go 在按照github.com/tools/godep文档go get完包以后,调整项目结构为$GOPATH/src/$PROJECT_NAME/,同时使项目编译没有问题.执行godep save命令,出现了一系列包缺失的问题: github.com/campoy/embedmd github.com/client9/misspell/cmd/misspell github.com/dustin/go-broadcas