Versions in this module Expand all Collapse all v1 v1.0.6 Mar 2, 2021 v1.0.5 Mar 2, 2021 Changes in this version + var ErrTaskIsBan = errors.New("task is ban") + var ErrTaskIsExist = errors.New("task is exist") + var ErrTaskIsNotExist = errors.New("task is not exist") + var ErrTaskIsUnBan = errors.New("task is already unban") + type CbFuncMap struct + func NewCbFuncMap() *CbFuncMap + func (fm *CbFuncMap) Add(i interface{}) + func (fm *CbFuncMap) Del(i interface{}) + func (fm *CbFuncMap) GetAll(out interface{}) int + type MultiTask struct + func NewMultiTask(routineCount int) *MultiTask + func (mt *MultiTask) Add(key string, t task.TaskObj, spec int, count int) + type SingleTask struct + func NewSingleTask(routineCount int) *SingleTask + func (st *SingleTask) Add(key string, task task.TaskObj, spec int) + type TimedTask struct + func NewTimedTask(maxRoutineCount int) *TimedTask + func (tt *TimedTask) Add(key string, obj task.TaskObj, sche task.ISchedule) + func (tt *TimedTask) AddAddCallback(cb func(*task.AddCbArgs)) + func (tt *TimedTask) AddBanCallback(cb func(*task.BanCbArgs)) + func (tt *TimedTask) AddCancelCallback(cb func(*task.CancelCbArgs)) + func (tt *TimedTask) AddExecuteCallback(cb func(*task.ExecuteCbArgs)) + func (tt *TimedTask) AddUnBanCallback(cb func(*task.UnBanCbArgs)) + func (tt *TimedTask) Ban(key string) + func (tt *TimedTask) Cancel(key string) + func (tt *TimedTask) DelAddCallback(cb func(*task.AddCbArgs)) + func (tt *TimedTask) DelBanCallback(cb func(*task.BanCbArgs)) + func (tt *TimedTask) DelCancelCallback(cb func(*task.CancelCbArgs)) + func (tt *TimedTask) DelExecuteCallback(cb func(*task.ExecuteCbArgs)) + func (tt *TimedTask) DelUnBanCallback(cb func(*task.UnBanCbArgs)) + func (tt *TimedTask) Execute(key string) + func (tt *TimedTask) GetTimedTaskInfo() map[string]*task.TaskInfo + func (tt *TimedTask) IsBan(key string) bool + func (tt *TimedTask) IsExist(key string) bool + func (tt *TimedTask) Set(key string, obj task.TaskObj, sche task.ISchedule) + func (tt *TimedTask) Stop() + func (tt *TimedTask) UnBan(key string)