Versions in this module Expand all Collapse all v1 v1.1.3 Sep 28, 2021 Changes in this version + type WorkerPool struct + func New(maxWorkers int) *WorkerPool + func (p *WorkerPool) Pause(ctx context.Context) + func (p *WorkerPool) SetPanicHandler(panicHandler func()) + func (p *WorkerPool) Size() int + func (p *WorkerPool) Stop() + func (p *WorkerPool) StopWait() + func (p *WorkerPool) Stopped() bool + func (p *WorkerPool) Submit(task func()) + func (p *WorkerPool) SubmitRecover(task func()) + func (p *WorkerPool) SubmitWait(task func()) + func (p *WorkerPool) WaitingQueueSize() int