concurrent

Documentation

Index

• type ObjPoll
  • func NewObjPoll(obj PoolGenerateItem, num int) *ObjPoll
  • func (p *ObjPoll) GetObj(timeout time.Duration) (interface{}, error)
  • func (p *ObjPoll) Release(obj interface{}) error
• type PoolGenerateItem

Types

type ObjPoll

type ObjPoll struct {
	// contains filtered or unexported fields
}

对象池

func NewObjPoll

func NewObjPoll(obj PoolGenerateItem, num int) *ObjPoll

创建对象池

func (*ObjPoll) GetObj

func (p *ObjPoll) GetObj(timeout time.Duration) (interface{}, error)

获取对象

func (*ObjPoll) Release

func (p *ObjPoll) Release(obj interface{}) error

放回对象

type PoolGenerateItem

type PoolGenerateItem func() interface{}