awesome_pool

README

awesome-pool

Documentation

Index

• type Pool
  • func NewPool(maxRoutine int, dialAddress string) (*Pool, error)
  • func (p *Pool) Free(n int)
  • func (p *Pool) Get() *msg

Types

type Pool

type Pool struct {
	MaxRoutine int
	Length     int
	T          []*connPool
	FN         func() net.Conn
	Freex      chan int
	N          []*msg
	sync.RWMutex
}

func NewPool

func NewPool(maxRoutine int, dialAddress string) (*Pool, error)

func (*Pool) Free

func (p *Pool) Free(n int)

func (*Pool) Get

func (p *Pool) Get() *msg

get a idle net.Conn