Method addFirst

pkg/task/queue/task_storage.go:28–34

Private methods (without locking) addFirst adds tasks to the front of the queue (internal implementation)

(tasks ...task.Task)

// addFirst adds tasks to the front of the queue (internal implementation)
func (ts *TaskStorage) addFirst(tasks ...task.Task) {
	// Add tasks in reverse order so the first task becomes the new head
	for i := len(tasks) - 1; i >= 0; i-- {
		element := ts.items.PushFront(tasks[i])
		ts.idIndex[tasks[i].GetId()] = element
	}
}

// removeFirst removes and returns the first task (internal implementation)
func (ts *TaskStorage) removeFirst() task.Task {