pool

Documentation

Index

• Variables
• type Pool
  • func New[T Poolable](fn func() (T, error), size uint) (*Pool[T], error)
  • func (p *Pool[T]) Acquire() (T, error)
  • func (p *Pool[T]) Close()
  • func (p *Pool[T]) Release(r T)
• type Poolable

Variables

var ErrPoolClosed = errors.New("Pool has been closed")

Types

type Pool

type Pool[T Poolable] struct {
	// contains filtered or unexported fields
}

func New

func New[T Poolable](fn func() (T, error), size uint) (*Pool[T], error)

New 函数工厂，指定有缓冲通道大小

func (*Pool[T]) Acquire

func (p *Pool[T]) Acquire() (T, error)

Acquire 池中获取资源

func (*Pool[T]) Close

func (p *Pool[T]) Close()

Close 池关闭所有现有资源

func (*Pool[T]) Release

func (p *Pool[T]) Release(r T)

Release 池中释放资源

type Poolable

type Poolable interface {
	Close() error
}