scheduler

Documentation

Index

• func MonitorRunningTaskToComplete()
• func MonitorSubtaskComplete()
• func MonitorTimeoutSubtask()
• func OnSubtaskCompleted(taskId taskmodel.TaskIdType, subtaskId uint64)
• func PerformCompleteTask(taskId uint64, ppipeline *redis.Pipeliner) error
• func ScheduleTaskRoutine()

Functions

func MonitorRunningTaskToComplete

func MonitorRunningTaskToComplete()

func MonitorSubtaskComplete

func MonitorSubtaskComplete()

监视已完成的子任务

func MonitorTimeoutSubtask

func MonitorTimeoutSubtask()

func OnSubtaskCompleted

func OnSubtaskCompleted(taskId taskmodel.TaskIdType, subtaskId uint64)

执行子任务后处理

func PerformCompleteTask

func PerformCompleteTask(taskId uint64, ppipeline *redis.Pipeliner) error

设置任务完成, 执行一些完成操作

func ScheduleTaskRoutine

func ScheduleTaskRoutine()

go_schedule_subtask