executor

Documentation

Index

• type ExecuteCloser
• type Executor
• type InPlace
  • func (*InPlace) Execute(t Task) bool
• type MultiFlow
  • func NewMultiFlow(parallel int, handoff, startImmediately bool) *MultiFlow
  • func (mf *MultiFlow) Close()
  • func (mf *MultiFlow) Init(parallel int, handoff, startImmediately bool) *MultiFlow
  • func (mf *MultiFlow) NewFlow() ExecuteCloser
  • func (mf *MultiFlow) Start()
• type Task

Types

type ExecuteCloser

type ExecuteCloser interface {
	Executor

	Close()
}

type Executor

type Executor interface {
	Execute(t Task) bool
}

type InPlace

type InPlace struct{}

func (*InPlace) Execute

func (*InPlace) Execute(t Task) bool

type MultiFlow

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

func NewMultiFlow

func NewMultiFlow(parallel int, handoff, startImmediately bool) *MultiFlow

func (*MultiFlow) Close

func (mf *MultiFlow) Close()

func (*MultiFlow) Init

func (mf *MultiFlow) Init(parallel int, handoff, startImmediately bool) *MultiFlow

func (*MultiFlow) NewFlow

func (mf *MultiFlow) NewFlow() ExecuteCloser

func (*MultiFlow) Start

func (mf *MultiFlow) Start()

type Task

type Task = func()