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