Documentation ¶
Index ¶
- Variables
- type AddCbArgs
- type BanCbArgs
- type CancelCbArgs
- type CbFuncMap
- type EveryDaySchedule
- type ExecuteCbArgs
- type Func
- type ISchedule
- type Map
- func (tm *Map) Add(key string, task *TaskInfo)
- func (tm *Map) AddOrSet(key string, task *TaskInfo)
- func (tm *Map) Delete(key string)
- func (tm *Map) Get(key string) *TaskInfo
- func (tm *Map) GetAll() map[string]*TaskInfo
- func (tm *Map) IsExist(key string) bool
- func (tm *Map) SelectNextExec() (*TaskInfo, time.Duration, bool)
- func (tm *Map) Set(key string, task *TaskInfo)
- type MultiTask
- type PlanSchedule
- type Result
- type SingleTask
- type SpecSchedule
- type SpecTimeSchedule
- type TaskInfo
- type TimedTask
- func (tt *TimedTask) Add(key string, obj Func, sche ISchedule)
- func (tt *TimedTask) AddAddCallback(cb func(*AddCbArgs))
- func (tt *TimedTask) AddBanCallback(cb func(*BanCbArgs))
- func (tt *TimedTask) AddCancelCallback(cb func(*CancelCbArgs))
- func (tt *TimedTask) AddExecuteCallback(cb func(*ExecuteCbArgs))
- func (tt *TimedTask) AddUnBanCallback(cb func(*UnBanCbArgs))
- func (tt *TimedTask) Ban(key string)
- func (tt *TimedTask) Cancel(key string)
- func (tt *TimedTask) DelAddCallback(cb func(*AddCbArgs))
- func (tt *TimedTask) DelBanCallback(cb func(*BanCbArgs))
- func (tt *TimedTask) DelCancelCallback(cb func(*CancelCbArgs))
- func (tt *TimedTask) DelExecuteCallback(cb func(*ExecuteCbArgs))
- func (tt *TimedTask) DelUnBanCallback(cb func(*UnBanCbArgs))
- func (tt *TimedTask) Execute(key string)
- func (tt *TimedTask) GetTimedTaskInfo() map[string]*TaskInfo
- func (tt *TimedTask) IsBan(key string) bool
- func (tt *TimedTask) Set(key string, obj Func, sche ISchedule)
- func (tt *TimedTask) Stop()
- func (tt *TimedTask) UnBan(key string)
- type TimerObj
- type UnBanCbArgs
Constants ¶
This section is empty.
Variables ¶
Functions ¶
This section is empty.
Types ¶
type CancelCbArgs ¶ added in v1.0.13
type CbFuncMap ¶
type CbFuncMap struct {
// contains filtered or unexported fields
}
func NewCbFuncMap ¶
func NewCbFuncMap() *CbFuncMap
type EveryDaySchedule ¶ added in v1.0.13
type EveryDaySchedule struct {
// contains filtered or unexported fields
}
每日指定时刻调度器
func NewEveryDaySchedule ¶ added in v1.0.13
func NewEveryDaySchedule(hour, minute, second, mSecond int) *EveryDaySchedule
func (*EveryDaySchedule) Expression ¶ added in v1.0.13
func (e *EveryDaySchedule) Expression(t *TaskInfo) (nt time.Time, isValid bool)
func (*EveryDaySchedule) ToString ¶ added in v1.0.13
func (e *EveryDaySchedule) ToString() string
type ExecuteCbArgs ¶ added in v1.0.13
type ISchedule ¶ added in v1.0.13
type ISchedule interface { Expression(t *TaskInfo) (nt time.Time, isValid bool) // 表达式 ToString() string }
任务调度接口
type Map ¶ added in v1.0.13
type Map struct {
// contains filtered or unexported fields
}
任务字典 线程安全
func NewTaskMap ¶ added in v1.0.13
func NewTaskMap() *Map
func (*Map) SelectNextExec ¶ added in v1.0.13
选择下一个最早执行的任务
type PlanSchedule ¶ added in v1.0.13
type PlanSchedule struct {
// contains filtered or unexported fields
}
指定时间点调度器
func NewPlanSchedule ¶ added in v1.0.13
func NewPlanSchedule(tList []time.Time) *PlanSchedule
func (*PlanSchedule) Expression ¶ added in v1.0.13
func (p *PlanSchedule) Expression(t *TaskInfo) (nt time.Time, isValid bool)
func (*PlanSchedule) ToString ¶ added in v1.0.13
func (p *PlanSchedule) ToString() string
type SingleTask ¶
type SingleTask struct {
*MultiTask
}
指定只执行一次定时任务
func NewSingleTask ¶
func NewSingleTask(routineCount int) *SingleTask
type SpecSchedule ¶ added in v1.0.13
type SpecSchedule struct {
// contains filtered or unexported fields
}
指定时长循环调度
func NewSpecSchedule ¶ added in v1.0.13
func NewSpecSchedule(spec time.Duration) *SpecSchedule
func (*SpecSchedule) Expression ¶ added in v1.0.13
func (p *SpecSchedule) Expression(t *TaskInfo) (nt time.Time, isValid bool)
func (*SpecSchedule) Record ¶ added in v1.0.13
func (p *SpecSchedule) Record(t *TaskInfo, cs ...int) (et []time.Time)
func (*SpecSchedule) ToString ¶ added in v1.0.13
func (p *SpecSchedule) ToString() string
type SpecTimeSchedule ¶ added in v1.0.13
type SpecTimeSchedule struct {
// contains filtered or unexported fields
}
指定时长指定次数调度器
func NewSpecTimeSchedule ¶ added in v1.0.13
func NewSpecTimeSchedule(spec time.Duration, time int) *SpecTimeSchedule
func (*SpecTimeSchedule) Expression ¶ added in v1.0.13
func (p *SpecTimeSchedule) Expression(t *TaskInfo) (nt time.Time, isValid bool)
func (*SpecTimeSchedule) ToString ¶ added in v1.0.13
func (p *SpecTimeSchedule) ToString() string
type TaskInfo ¶ added in v1.0.13
type TaskInfo struct { Key string // 任务标志key Task Func // 任务方法 LastTime time.Time // 最后一次执行任务的时间(未执行过时为time.Time{}) AddTime time.Time // 任务添加的时间 NextTime time.Time // 下次执行时间 Count int // 任务执行次数 Schedule ISchedule // 任务计划 HasNext bool // 是否还有下一次执行 LastResult *Result // 任务最后一次执行的结果 // contains filtered or unexported fields }
func NewTaskInfo ¶ added in v1.0.13
创建一个任务信息对象
func (*TaskInfo) GetAddTaskTime ¶ added in v1.0.13
任务添加时间
func (*TaskInfo) GetLastExecuteTime ¶ added in v1.0.13
最后一次执行时间
func (*TaskInfo) HasNextExecute ¶ added in v1.0.13
是否还有下一次执行
func (*TaskInfo) NextScheduleTime ¶ added in v1.0.13
下次执行时间
type TimedTask ¶
type TimedTask struct {
// contains filtered or unexported fields
}
func NewTimedTask ¶
func (*TimedTask) AddAddCallback ¶
func (*TimedTask) AddBanCallback ¶
func (*TimedTask) AddCancelCallback ¶
func (tt *TimedTask) AddCancelCallback(cb func(*CancelCbArgs))
func (*TimedTask) AddExecuteCallback ¶
func (tt *TimedTask) AddExecuteCallback(cb func(*ExecuteCbArgs))
func (*TimedTask) AddUnBanCallback ¶
func (tt *TimedTask) AddUnBanCallback(cb func(*UnBanCbArgs))
func (*TimedTask) DelAddCallback ¶
func (*TimedTask) DelBanCallback ¶
func (*TimedTask) DelCancelCallback ¶
func (tt *TimedTask) DelCancelCallback(cb func(*CancelCbArgs))
func (*TimedTask) DelExecuteCallback ¶
func (tt *TimedTask) DelExecuteCallback(cb func(*ExecuteCbArgs))
func (*TimedTask) DelUnBanCallback ¶
func (tt *TimedTask) DelUnBanCallback(cb func(*UnBanCbArgs))
func (*TimedTask) GetTimedTaskInfo ¶
获取定时任务列表信息
type UnBanCbArgs ¶ added in v1.0.13
type UnBanCbArgs BanCbArgs
Source Files ¶
Click to show internal directories.
Click to hide internal directories.