schedulerlogic

Documentation

Index

• func AddTaskToScheduler(taskId taskmodel.TaskIdType, groupName string, taskType uint32, ...) error
• func DispatchSubtask(taskType uint32, callback taskmodel.ITaskSchedulerCallback, ...) error
• func ExecSubtasks(taskId taskmodel.TaskIdType, subtasks *[]taskmodel.SubtaskBody, ...) error
• func GetTaskSchedulerCallback(taskType uint32, callback *taskmodel.ITaskSchedulerCallback) error
• func ScheduleSubtasks(retTaskId *taskmodel.TaskIdType, subtasks *[]taskmodel.SubtaskBody) error

Functions

func AddTaskToScheduler

func AddTaskToScheduler(
	taskId taskmodel.TaskIdType,
	groupName string,
	taskType uint32,
	priority uint32,
) error

func DispatchSubtask

func DispatchSubtask(
	taskType uint32,
	callback taskmodel.ITaskSchedulerCallback,
	subtask *taskmodel.SubtaskBody,
) error

对子任务执行调度操作

func ExecSubtasks

func ExecSubtasks(
	taskId taskmodel.TaskIdType,
	subtasks *[]taskmodel.SubtaskBody,
	toPushbackSubtask *[]taskmodel.SubtaskBody,
) error

execute subtasks belonging to the same task

func GetTaskSchedulerCallback

func GetTaskSchedulerCallback(taskType uint32, callback *taskmodel.ITaskSchedulerCallback) error

func ScheduleSubtasks

func ScheduleSubtasks(
	retTaskId *taskmodel.TaskIdType,
	subtasks *[]taskmodel.SubtaskBody,
) error

if no task, retTaskId is 0, subtasks is empty