Golang -- 使用 Bufferd channel 实现 线程安全的 pool

概述

sync.Pool

代码

type Pool struct {
pool chan *Client
}

// Create a new Pool
func NewPool(max int) *Pool{
return &Pool{
pool: make(chan *Client, max)
}
}

// Get a Client from Pool
func (p *Pool) Borrow() *Client {
var cl *Client
select {
case cl = <-p.pool:
default:
c1 = newClient()
}
return cl
}

// Return the Cliet to the pool
func (p *Pool) Return(cl *Client){
select {
case p.pool<- cl:
default:
// let it go, let it go....
}
}

sync.Pool