parallel

Documentation

Index

• func RunByContext(ctx context.Context, runner ...func(ctx context.Context))
• func RunParallel(ctx context.Context, runner ...func(ctx context.Context))
• type Port
• type Root
  • 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 RunInfo
• 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) Fork(runFunc func(ctx context.Context) bool) *Runner
  • func (runner *Runner) ForkEmpty(ctx context.Context) *Runner
  • func (runner *Runner) Separate()

Functions

func RunByContext

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

func RunParallel

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

Types

type Port

type Port struct {
	// contains filtered or unexported fields
}

type Root

type Root struct {
	// contains filtered or unexported fields
}

func NewRoot

func NewRoot() *Root

func (*Root) Close

func (root *Root) Close()

func (*Root) Closed

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

func (*Root) Fork

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

func (*Root) Runner

func (root *Root) Runner() *Runner

func (*Root) Start

func (root *Root) Start()

type RunInfo

type RunInfo struct {
	Started bool
	End     bool
	RetErr  error
}

type Runner

type Runner struct {
	// contains filtered or unexported fields
}

func Empty

func Empty() *Runner

func New

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

func (*Runner) Closed

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

func (*Runner) DependOn

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

func (*Runner) Fork

func (runner *Runner) Fork(runFunc func(ctx context.Context) bool) *Runner

func (*Runner) ForkEmpty

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

func (*Runner) Separate

func (runner *Runner) Separate()