task

type CatchFn func(err error)

type Controller interface {
	Pause() error
	Resume() error
	Cancel() error
	GetState() State
	GetStatus() Status
	GetError() error
	GetProgress() map[string]*Progress
}

type Executor interface {
	Execute(r Runnable)
}

type FinallyFn func()

type Progress struct {
	TaskID    string // 任务ID
	Name      string // 项目名称(ID)
	Title     string // 标题
	Unit      string // 单位
	Value     int64  // 当前值
	ValueMin  int64  // 最小值
	ValueMax  int64  // 最大值
	TimeBegin int64  // 开始时间
	TimeEnd   int64  // 结束时间
	Done      bool   // 是否已完成
	Cancelled bool   // 是否已取消
}

type ProgressControlHandlerFn func(reporter ProgressReporter) error

type ProgressReporter interface {
	Report(p *Progress)
	UpdateStatus(s Status)
	UpdateState(s State)

	HandleCancel(f ProgressControlHandlerFn)
	HandlePause(f ProgressControlHandlerFn)
	HandleResume(f ProgressControlHandlerFn)
}

type Promise interface {
	Then(fn ThenFn) Promise
	Catch(fn CatchFn) Promise
	Finally(fn FinallyFn) Promise
}

type PromiseFn func(resolve ResolveFn, reject RejectFn)

type RejectFn func(err error)

type ResolveFn func(result interface{})

type Runnable interface {
	// Run 在当前协程上执行任务
	Run()
}

type State int

type Status uint

type ThenFn func(result interface{})