xpool

Documentation

Index

• type ExpireFunc
• type NewFunc
• type TPool
  • func New(expire time.Duration, newFunc NewFunc, expireFunc ...ExpireFunc) *TPool
  • func (p *TPool) Clear()
  • func (p *TPool) Close()
  • func (p *TPool) Get() (interface{}, error)
  • func (p *TPool) Put(value interface{})
  • func (p *TPool) Size() int

Types

type ExpireFunc

type ExpireFunc func(interface{})

type NewFunc

type NewFunc func() (interface{}, error)

type TPool

type TPool struct {
	Expire     time.Duration
	NewFunc    func() (interface{}, error)
	ExpireFunc func(interface{})
	// contains filtered or unexported fields
}

线程池

func New

func New(expire time.Duration, newFunc NewFunc, expireFunc ...ExpireFunc) *TPool

func (*TPool) Clear

func (p *TPool) Clear()

清空线程池

func (*TPool) Close

func (p *TPool) Close()

关闭线程池

func (*TPool) Get

func (p *TPool) Get() (interface{}, error)

从线程池中获取一项

func (*TPool) Put

func (p *TPool) Put(value interface{})

对象放入到线程池

func (*TPool) Size

func (p *TPool) Size() int

获取池大小