task

Documentation

Index

• Variables
• type Runner
  • func New(tm time.Duration) *Runner
  • func (r *Runner) Add(tasks ...func())
  • func (r *Runner) Start() error

Variables

var ErrInterruput = errors.New("run interruput")

任务执行中断

var ErrTimeOut = errors.New("run time out")

任务执行超时

Types

type Runner

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

后台执行任何限时任务，而且我们还可以控制这个执行者，比如强制终止它等

func New

func New(tm time.Duration) *Runner

工厂方法

func (*Runner) Add

func (r *Runner) Add(tasks ...func())

func (*Runner) Start

func (r *Runner) Start() error

开始执行所有任务，并且监视通道事件