parallel

Apr 20, 2021

Changes in this version

type RunnerOption

+ func WithTicket(l int) RunnerOption

Apr 20, 2021

Changes in this version

+ type Runner struct

+ func NewRunner(opts ...RunnerOption) *Runner

+ func (p *Runner) Add(fn func() (interface{}, error))

+ func (p *Runner) Run() []State

+ func (p *Runner) RunSerial() []State

+ type RunnerOption func(*Runner)

+ func WithLimit(l int) RunnerOption

+ type State struct

+ Err error

+ Val interface{}