scheduler

Documentation

Index

• func PopTaskId(keyName string, retTaskId *taskmodel.TaskIdType) error
• func ScheduleTaskInQueue(keyName string, retTaskId *taskmodel.TaskIdType, noTask *bool) error
• type FCFSScheduler
  • func (scheduler *FCFSScheduler) Schedule(retTaskId *taskmodel.TaskIdType, noTask *bool) error
• type IQueueScheduler
• type RRScheduler
  • func (scheduler *RRScheduler) Schedule(retTaskId *taskmodel.TaskIdType, noTask *bool) error

Functions

func PopTaskId

func PopTaskId(
	keyName string,
	retTaskId *taskmodel.TaskIdType,
) error

取队首的任务ID元素

func ScheduleTaskInQueue

func ScheduleTaskInQueue(
	keyName string,
	retTaskId *taskmodel.TaskIdType,
	noTask *bool,
) error

从队列中取出任务ID

Types

type FCFSScheduler

type FCFSScheduler struct {
	QueueKeyName string // 队列的Key名
}

FCFS调度算法

func (*FCFSScheduler) Schedule

func (scheduler *FCFSScheduler) Schedule(
	retTaskId *taskmodel.TaskIdType,
	noTask *bool,
) error

FCFS调度算法

type IQueueScheduler

type IQueueScheduler interface {
	Schedule(taskId *taskmodel.TaskIdType, noTask *bool) error
}

type RRScheduler

type RRScheduler struct {
	QueueKeyName string
}

RR调度算法

func (*RRScheduler) Schedule

func (scheduler *RRScheduler) Schedule(
	retTaskId *taskmodel.TaskIdType,
	noTask *bool,
) error

RR调度算法