worker

Feb 19, 2024

Changes in this version

+ type Pool struct

+ func NewWorkerPool(size int) *Pool

+ func (p *Pool) Start(ctx context.Context)

+ func (p *Pool) Stop()

+ func (p *Pool) Submit(task func(context.Context))

Jan 26, 2024

Changes in this version

+ type Worker interface

+ Done func() <-chan struct{}

+ Start func(context.Context)

+ Stop func()

+ func NewWorker(run func(context.Context)) Worker