generationqueue

Documentation

Index

• Constants
• func GetGenerationQueueOfTask(taskId taskmodel.TaskIdType) string
• func GetSubtaskCount(taskId taskmodel.TaskIdType) (uint, error)
• func PushSubtaskBack(taskId taskmodel.TaskIdType, subtasks *[]taskmodel.SubtaskBody) error
• type GenerationQueue
  • func (queue *GenerationQueue) GetSubtaskCount(taskId taskmodel.TaskIdType) (uint, error)
  • func (queue *GenerationQueue) Pop(subtask *taskmodel.SubtaskBody) error
  • func (queue *GenerationQueue) Push(subtask *taskmodel.SubtaskBody) error
• type GenerationiQueueMgr
  • func (mgr *GenerationiQueueMgr) AddTask(taskId taskmodel.TaskIdType) error
  • func (mgr *GenerationiQueueMgr) PopSubtask(taskId taskmodel.TaskIdType, subtask *taskmodel.SubtaskBody) error
  • func (mgr *GenerationiQueueMgr) PushSubtask(taskId taskmodel.TaskIdType, subtask *taskmodel.SubtaskBody) error
  • func (mgr *GenerationiQueueMgr) RemoveTask(taskId taskmodel.TaskIdType) error

Constants

const (
	// 任务下的待调度的子任务队列, to_schedule_subtask_list.$taskid, list
	ToScheduleSubtaskSetOfTaskPrefix = "dtf.task.to.schedule.subtask.list."
)

任务的子任务队列

Functions

func GetGenerationQueueOfTask

func GetGenerationQueueOfTask(taskId taskmodel.TaskIdType) string

获取任务的子任务队列的键名

func GetSubtaskCount

func GetSubtaskCount(taskId taskmodel.TaskIdType) (uint, error)

判断子任务队列中子任务的数量

func PushSubtaskBack

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

将子任务推回任务的子任务生成列表中

Types

type GenerationQueue

type GenerationQueue struct {
	TaskId taskmodel.TaskIdType
}

任务的子任务队列 一个任务一个子任务队列

func (*GenerationQueue) GetSubtaskCount

func (queue *GenerationQueue) GetSubtaskCount(taskId taskmodel.TaskIdType) (uint, error)

判断子任务队列中子任务的数量

func (*GenerationQueue) Pop

func (queue *GenerationQueue) Pop(subtask *taskmodel.SubtaskBody) error

从子任务队列中取子任务

func (*GenerationQueue) Push

func (queue *GenerationQueue) Push(subtask *taskmodel.SubtaskBody) error

将子任务放入子任务队列中

type GenerationiQueueMgr

type GenerationiQueueMgr struct {
	GenerationQueueMap map[taskmodel.TaskIdType]*GenerationQueue // 各任务的子任务队列表
}

管理当前生成器实例下的所有任务的子任务队列

func (*GenerationiQueueMgr) AddTask

func (mgr *GenerationiQueueMgr) AddTask(taskId taskmodel.TaskIdType) error

添加任务 当创建任务、恢复任务生成时，执行添加操作

func (*GenerationiQueueMgr) PopSubtask

func (mgr *GenerationiQueueMgr) PopSubtask(
	taskId taskmodel.TaskIdType,
	subtask *taskmodel.SubtaskBody,
) error

从子任务队列中取子任务

func (*GenerationiQueueMgr) PushSubtask

func (mgr *GenerationiQueueMgr) PushSubtask(
	taskId taskmodel.TaskIdType,
	subtask *taskmodel.SubtaskBody,
) error

将子任务放入子任务队列中

func (*GenerationiQueueMgr) RemoveTask

func (mgr *GenerationiQueueMgr) RemoveTask(taskId taskmodel.TaskIdType) error

删除任务 当任务完成时，执行删除操作