Task

Documentation

Index

• func GetCronTask() *cron.Cron
• func Task(f TaskFunc, cb func(), params ...interface{})
• func TaskMustBefore(job func(in InChan), d time.Duration) (interface{}, error)
• type InChan
• type SetInterVal
  • func New() *SetInterVal
  • func (this *SetInterVal) Do(cron string, exprorfunc interface{}) *SetInterVal
• type TaskExecutor
  • func NewTaskExecutor(f TaskFunc, p []interface{}, callback func()) *TaskExecutor
  • func (this *TaskExecutor) Exec()
• type TaskFunc
• type TaskLmit
  • func LimtTask(maxNum int) *TaskLmit
  • func (this *TaskLmit) CanDo()
  • func (this *TaskLmit) Close()

Functions

func GetCronTask

func GetCronTask() *cron.Cron

初始化定时任务器

func Task

func Task(f TaskFunc, cb func(), params ...interface{})

func TaskMustBefore

func TaskMustBefore(job func(in InChan), d time.Duration) (interface{}, error)

Types

type InChan

type InChan chan interface{}

type SetInterVal

type SetInterVal struct {
}

var CronInstance *SetInterVal

func New

func New() *SetInterVal

func (*SetInterVal) Do

func (this *SetInterVal) Do(cron string, exprorfunc interface{}) *SetInterVal

type TaskExecutor

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

func NewTaskExecutor

func NewTaskExecutor(f TaskFunc, p []interface{}, callback func()) *TaskExecutor

辅助函数 初始化任务器

func (*TaskExecutor) Exec

func (this *TaskExecutor) Exec()

type TaskFunc

type TaskFunc func(params ...interface{})

type TaskLmit

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

func LimtTask

func LimtTask(maxNum int) *TaskLmit

控制任务数

func (*TaskLmit) CanDo

func (this *TaskLmit) CanDo()

func (*TaskLmit) Close

func (this *TaskLmit) Close()