Method CreateQueueTask

tasks.go:243–252

CreateQueueTask create new queue task and register to task service

(taskID string, isRun bool, interval int64, handler TaskHandle, taskData interface{}, queueSize int64)

// CreateQueueTask create new queue task and register to task service
func (service *TaskService) CreateQueueTask(taskID string, isRun bool, interval int64, handler TaskHandle, taskData interface{}, queueSize int64) (Task, error) {
	task, err := NewQueueTask(taskID, isRun, interval, handler, taskData, queueSize)
	if err != nil {
		return task, err
	}

	task.SetTaskService(service)
	service.AddTask(task)
	return task, nil
}

// GetTask get TaskInfo by TaskID
func (service *TaskService) GetTask(taskID string) (t Task, exists bool) {