dpool

Documentation

Index

• type ExpireFunc
• type NewFunc
• type Pool
  • func New(ttl time.Duration, newFunc NewFunc, expireFunc ...ExpireFunc) *Pool
  • func (that *Pool) Clear()
  • func (that *Pool) Close()
  • func (that *Pool) Get() (interface{}, error)
  • func (that *Pool) Put(value interface{}) error
  • func (that *Pool) Size() int
• type SyncPool
  • func NewSyncPool(newFunc func() interface{}, init func(interface{})) *SyncPool
  • func (that *SyncPool) Get() interface{}
  • func (that *SyncPool) Put(value interface{})

Types

type ExpireFunc

type ExpireFunc func(interface{})

type NewFunc

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

type Pool

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

Pool 并发安全的对象复用池

func New

func New(ttl time.Duration, newFunc NewFunc, expireFunc ...ExpireFunc) *Pool

New 创建对象池 注意： ttl = 0: 表示不过期。 ttl < 0: 使用后立即过期 ttl > 0: 设置的过期时间

func (*Pool) Clear

func (that *Pool) Clear()

Clear 清除对象池

func (*Pool) Close

func (that *Pool) Close()

Close 关闭该对象池

func (*Pool) Get

func (that *Pool) Get() (interface{}, error)

Get 从对象池中获取对象，如果池中不存在对象，则调用对象生成方法生成对象

func (*Pool) Put

func (that *Pool) Put(value interface{}) error

Put 把对象放回对象池

func (*Pool) Size

func (that *Pool) Size() int

Size 对象池中的对象数目

type SyncPool

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

func NewSyncPool

func NewSyncPool(newFunc func() interface{}, init func(interface{})) *SyncPool

NewSyncPool 创建对象池 newFunc：创建对象的方法 init： 对象被创建后，返回之前，调用该方法初始化对象

func (*SyncPool) Get

func (that *SyncPool) Get() interface{}

Get 获取对象

func (*SyncPool) Put

func (that *SyncPool) Put(value interface{})

Put 把对象放回对象池