安装

go get github.com/go-basic/pool

实现接口

type DemoCloser struct {
	Conn     net.Conn
	activeAt time.Time
}

func (p *DemoCloser) Close() error {
	return p.Conn.Close()
}

func (p *DemoCloser) GetActiveTime() time.Time {
	return p.activeAt
}

使用

	p, err := pool.NewGenericPool(2, 5, 30*time.Second, func() (poolable pool.Poolable, e error) {
		conn, err := net.Dial("tcp", addr)
		if err != nil {
			return nil, err
		}
		return &DemoCloser{Conn: conn, activeAt: time.Now()}, nil
	})
	if err != nil {
		fmt.Println("err=", err)
	}

	//从连接池中取得一个连接
	v, err := p.Get()

	//todo
	//conn=v.(net.Conn)

	//将连接放回连接池中
	p.Put(v)

	//释放连接池中的所有连接
	//p.Release()

	//查看当前连接中的数量
	current := p.Len()
	fmt.Println("len=", current)

更多见example

https://github.com/go-basic/pool/blob/master/example/main.go