runners

Documentation

Index

• type Runner
  • func NewRunner(parent context.Context, downChan chan<- struct{}) *Runner
  • func (r *Runner) RunWorker(fns ...func(ctx context.Context))
  • func (r *Runner) Stop()

Types

type Runner

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

func NewRunner

func NewRunner(parent context.Context, downChan chan<- struct{}) *Runner

func (*Runner) RunWorker

func (r *Runner) RunWorker(fns ...func(ctx context.Context))

RunWorker 单独拉起携程执行某个函数，并拦截 panic 并在一秒之后重新启动 这个执行函数，一般都是阻塞的

func (*Runner) Stop

func (r *Runner) Stop()

Stop 结束任务执行器