Documentation ¶
Overview ¶
Package execute
Package execute
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Executor ¶
type Executor interface { // Logger 设置logger Logger(logger log.Log) // Clear 清除已有任务 Clear() // Empty 判断是否有任务 Empty() bool // Count 获取任务数量 Count() int // AddFixed 添加需要执行的任务,函数必须为:executorFunc AddFixed(f executorFunc, param ...interface{}) Executor // AddFlexible 推荐此方法, 参数可以为空,返回值必须是:any, error,其中 any 可以是 interface 或者其他自定义类型 // 添加任务,函数格式必须为: // taskfunc(param ...interface{}) (interface{}, error) // 或自定义参数 // taskfunc(i int, s string, arr []int) (interface{}, error) AddFlexible(f interface{}, param ...interface{}) Executor // Execute 执行任务,返回任务结果,不返回任务error以及执行error Execute(ctx context.Context) ([]interface{}, error) // ExecuteWithErr 执行任务,返回任务结果和任务error以及执行error ExecuteWithErr(ctx context.Context) ([]interface{}, []error, error) }
func NewExecutor ¶
Click to show internal directories.
Click to hide internal directories.