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();
}

相关文章
相关标签/搜索