qroutine

Documentation

Index

• func Exec(timeout time.Duration, boxes ...*Box)
• type Box
  • func NewBox(routine SimpleRoutine, arg interface{}) *Box
  • func (o *Box) GetResult() (interface{}, error)
  • func (o *Box) GetState() BoxState
  • func (o *Box) Go()
• type BoxState
• type SimpleRoutine
• type Timer
  • func (o *Timer) Start(delay time.Duration, interval time.Duration, routine TimerRoutine) error
  • func (o *Timer) Stop()
  • func (o *Timer) Wake()
• type TimerRoutine

Functions

func Exec

func Exec(timeout time.Duration, boxes ...*Box)

timeout < 0 no wait, timeout == 0 wait until all done

Types

type Box

type Box struct {
	Arg     interface{}
	Routine SimpleRoutine
	// contains filtered or unexported fields
}

func NewBox

func NewBox(routine SimpleRoutine, arg interface{}) *Box

func (*Box) GetResult

func (o *Box) GetResult() (interface{}, error)

func (*Box) GetState

func (o *Box) GetState() BoxState

func (*Box) Go

func (o *Box) Go()

type BoxState

type BoxState int

const (
	PENDING BoxState = iota
	RUNNING
	FINISH
	ERROR
)

type SimpleRoutine

type SimpleRoutine func(arg interface{}) interface{}

type Timer

type Timer struct {
	Context interface{}
	// contains filtered or unexported fields
}

func (*Timer) Start

func (o *Timer) Start(delay time.Duration, interval time.Duration, routine TimerRoutine) error

func (*Timer) Stop

func (o *Timer) Stop()

func (*Timer) Wake

func (o *Timer) Wake()

type TimerRoutine

type TimerRoutine func(timer *Timer, err error)