Method AddFirst

pkg/task/queue/task_queue.go:295–304

AddFirst adds new head element.

(tasks ...task.Task)

// AddFirst adds new head element.
func (q *TaskQueue) AddFirst(tasks ...task.Task) {
	defer q.MeasureActionTime("AddFirst")()

	q.storage.AddFirst(tasks...)

	// Update queueTasksCounter for each added task
	for _, t := range tasks {
		q.queueTasksCounter.Add(t)
	}
}

// RemoveFirst deletes a head element, so head is moved.
func (q *TaskQueue) RemoveFirst() task.Task {