pool

Dec 4, 2022

Changes in this version

+ type FixedGoroutinePool struct

+ func NewFixedGoroutinePool(options ...fixedOption) *FixedGoroutinePool

+ func (pool *FixedGoroutinePool) Schedule(task func())

+ func (pool *FixedGoroutinePool) Stop()

+ type FixedOptions struct

+ Block bool

+ Num int

type Options

+ Block bool

+ type ScalableGroutinePool struct

+ func (p *ScalableGroutinePool) Schedule(task func())

+ func (p *ScalableGroutinePool) Stop()

type Worker

+ func (w *Worker) Stop()

+ func (w *Worker) Submit(task f, block bool)

Nov 26, 2022

Changes in this version

+ type Provider interface

+ Acquire func() Object

+ Release func(obj Object)

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

+ type SyncPoolProvider struct

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

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

Nov 15, 2022

Changes in this version

type GoroutinePool

+ func (p *GoroutinePool) Stop()

+ type Option func(options *Options)

+ type Options struct

+ Idle int

+ Max int32

+ Timeout time.Duration

type Worker

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

type WorkerPool

+ Stop func()

Oct 18, 2022

Changes in this version

+ type GoroutinePool struct

+ func NewGoroutinePool(size int) *GoroutinePool

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

+ type Worker interface

+ Schedule func(fn func())

+ type WorkerPool struct

+ func NewWorkerPool(size int) *WorkerPool

+ func (pool WorkerPool) Schedule(fn func())

Aug 25, 2022

Changes in this version

+ var GetByte = builtinPool.Get

+ var PutByte = builtinPool.Put

+ type BytePool struct

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

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