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 DefaultProgressReporter struct {
}

type DefaultProgressReporterFactory struct {
}

type Executor interface {
	Execute(r Runnable)
}

type FinallyFn func()

type Progress struct {
	TaskID  string // 任务ID
	Name    string // 项目名称(ID)
	Title   string // 标题
	Unit    string // 单位
	Message string // 描述当前进度的消息

	Value     int64 // 当前值
	ValueMin  int64 // 最小值
	ValueMax  int64 // 最大值
	TimeBegin int64 // 开始时间
	TimeEnd   int64 // 结束时间

	// Done      bool // 是否已完成 (已废弃，用 State)
	// Cancelled bool // 是否已取消（已废弃，用 Statue）
	State  State  // 过程中的状态
	Status Status // 最终状态
}

type ProgressControlHandlerFn func(reporter ProgressReporter) error

type ProgressReporter interface {
	Report(p *Progress)

	// Update 更新状态 state|status
	Update(p *Progress)

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

type ProgressReporterFactory interface {
	Create() ProgressReporter
}

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

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{})