pool

Documentation

Index

• Variables
• type BytePool
  • func (p *BytePool) Get(size int) (buf []byte)
  • func (p *BytePool) Put(buf []byte)
• type GoroutinePool
  • func NewGoroutinePool(opts ...Option) *GoroutinePool
  • func (p *GoroutinePool) Schedule(task func())
  • func (p *GoroutinePool) Stop()
• type Option
• type Options
• type Provider
  • func NewSyncPoolProvider[Object any](constructor func() interface{}) Provider[Object]
• type SyncPoolProvider
  • func (provider *SyncPoolProvider[Object]) Acquire() Object
  • func (provider *SyncPoolProvider[Object]) Release(obj Object)
• type Worker
  • func NewWorker(pool *GoroutinePool, size int) *Worker
• type WorkerPool

Variables

var (
	// GetByte retrieves a byte slice but uses the global pool
	GetByte = builtinPool.Get
	// PutByte returns a byte slice but uses the global pool
	PutByte = builtinPool.Put
)

Types

type BytePool

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

Pool consists of 32 sync.Pool, representing byte slices of length from 0 to 32 in powers of 2.

func (*BytePool) Get

func (p *BytePool) Get(size int) (buf []byte)

Get retrieves a byte slice of the length requested by the caller from pool or allocates a new one.

func (*BytePool) Put

func (p *BytePool) Put(buf []byte)

Put returns the byte slice to the pool.

type GoroutinePool

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

func NewGoroutinePool

func NewGoroutinePool(opts ...Option) *GoroutinePool

func (*GoroutinePool) Schedule

func (p *GoroutinePool) Schedule(task func())

Schedule 执行任务

func (*GoroutinePool) Stop

func (p *GoroutinePool) Stop()

Stop 停止协程池

type Option

type Option func(options *Options)

type Options

type Options struct {
	Max     int32         // maximum number of workers
	Idle    int           // idle number of workers
	Timeout time.Duration // quit time for worker
}

type Provider

type Provider[Object any] interface {
	Acquire() Object
	Release(obj Object)
}

Provider represents a object provider

func NewSyncPoolProvider

func NewSyncPoolProvider[Object any](constructor func() interface{}) Provider[Object]

type SyncPoolProvider

type SyncPoolProvider[Object any] struct {
	// contains filtered or unexported fields
}

func (*SyncPoolProvider[Object]) Acquire

func (provider *SyncPoolProvider[Object]) Acquire() Object

func (*SyncPoolProvider[Object]) Release

func (provider *SyncPoolProvider[Object]) Release(obj Object)

type Worker

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

func NewWorker

func NewWorker(pool *GoroutinePool, size int) *Worker

type WorkerPool

type WorkerPool interface {
	Schedule(task func())
	Stop()
}