timer

Documentation

Index

• type Timer
  • func NewTimer() *Timer
  • func (t *Timer) AddTaskByFunc(taskName string, spec string, task func()) (cron.EntryID, error)
  • func (t *Timer) AddTaskByJob(taskName string, spec string, job interface{ ... }) (cron.EntryID, error)
  • func (t *Timer) Clear(taskName string)
  • func (t *Timer) Close()
  • func (t *Timer) FindCron(taskName string) (*cron.Cron, bool)
  • func (t *Timer) Remove(taskName string, id int)
  • func (t *Timer) StartTask(taskName string)
  • func (t *Timer) StopTask(taskName string)

Types

type Timer

type Timer struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Timer 定时任务管理

func NewTimer

func NewTimer() *Timer

func (*Timer) AddTaskByFunc

func (t *Timer) AddTaskByFunc(taskName string, spec string, task func()) (cron.EntryID, error)

AddTaskByFunc 通过函数的方法添加任务

func (*Timer) AddTaskByJob

func (t *Timer) AddTaskByJob(taskName string, spec string, job interface{ Run() }) (cron.EntryID, error)

AddTaskByJob 通过接口的方法添加任务

func (*Timer) Clear

func (t *Timer) Clear(taskName string)

Clear 清除任务

func (*Timer) Close

func (t *Timer) Close()

Close 释放资源

func (*Timer) FindCron

func (t *Timer) FindCron(taskName string) (*cron.Cron, bool)

FindCron 获取对应taskName的cron 可能会为空

func (*Timer) Remove

func (t *Timer) Remove(taskName string, id int)

Remove 从taskName 删除指定任务

func (*Timer) StartTask

func (t *Timer) StartTask(taskName string)

StartTask 开始任务

func (*Timer) StopTask

func (t *Timer) StopTask(taskName string)

StopTask 停止任务