parallel

Sep 11, 2019

Changes in this version

+ func RunByContext(ctx context.Context, runner ...func(ctx context.Context))

+ type RunInfo struct

+ End bool

+ RetErr error

+ Started bool

Sep 6, 2019

Changes in this version

+ func RunParallel(ctx context.Context, runner ...func(ctx context.Context))

Sep 2, 2019

Changes in this version

+ type Port struct

+ type Root struct

+ func NewRoot() *Root

+ func (root *Root) Close()

+ func (root *Root) Closed() <-chan struct{}

+ func (root *Root) Fork(runner func(ctx context.Context) bool) *Runner

+ func (root *Root) Runner() *Runner

+ func (root *Root) Start()

type Runner

+ func Empty() *Runner

+ func New(runFunc func(ctx context.Context) bool) *Runner

+ func (runner *Runner) Closed() <-chan struct{}

+ func (runner *Runner) DependOn(dependOn ...*Runner)

+ func (runner *Runner) ForkEmpty(ctx context.Context) *Runner

+ func (runner *Runner) Separate()

Aug 29, 2019

Changes in this version

+ func Run(ctx context.Context, exitWait time.Duration, ...) error

+ type Prob struct

+ type Runner struct

+ func (p *Runner) ActualStatus()

+ func (p *Runner) ExpectStatus()

+ func (p *Runner) Fork(parallel *Runner)

+ func (p *Runner) ForkGroup(coupled bool, runner ...func(ctx context.Context) error)

+ func (p *Runner) Stop()