Versions in this module Expand all Collapse all v1 v1.0.0 May 18, 2022 Changes in this version + type Task interface + Invoke func(ctx context.Context) error + type TaskOption func(j *job) + func Retry(b bool) TaskOption + func RetryMax(n int) TaskOption + type WorkerPool struct + func New(n int64) WorkerPool + func (p *WorkerPool) Push(t Task, opts ...TaskOption) + func (p *WorkerPool) Run(ctx context.Context) + func (p WorkerPool) Wait() Other modules containing this package github.com/tniswong/workerpool/v2