Versions in this module Expand all Collapse all v0 v0.38.0 Jun 12, 2023 Changes in this version + type ParallelRunner struct + func NewParallelRunner(ctx context.Context, maxRun int64) *ParallelRunner + func (p *ParallelRunner) DoneChan() <-chan struct{} + func (p *ParallelRunner) Err() error + func (p *ParallelRunner) Read() chan interface{} + func (p *ParallelRunner) Run(runnable func() (interface{}, error)) + func (p *ParallelRunner) Stop(err error) + func (p *ParallelRunner) SubRunner() *ParallelRunner
Go to main page