worker

Feb 24, 2024

Changes in this version

+ type DirectWorker struct

+ func (DirectWorker) Submit(task func())

+ func (DirectWorker) SubmitAndWait(task func())

+ func (DirectWorker) SubmitBefore(task func(), dur time.Duration)

+ type Pond struct

+ func CreateNewPond(targetName string) *Pond

+ func NewPond(max int, poolSize int, workers ...pond.Option) *Pond

+ func (p *Pond) Submit(task func())

+ func (p *Pond) SubmitAndWait(task func())

+ func (p *Pond) SubmitBefore(task func(), dur time.Duration)

+ type Worker interface

+ Submit func(task func())

+ SubmitAndWait func(task func())

+ SubmitBefore func(task func(), dur time.Duration)

+ func Get(name ...string) Worker