Method RunTaskInBackground

task/list.go:201–231

RunTaskInBackground creates task and runs it in background. This will block until the necessary resources become available.

(name string, resources []string, process Process)

// RunTaskInBackground creates task and runs it in background. This will block until the necessary resources
// become available.
func (list *List) RunTaskInBackground(name string, resources []string, process Process) (Task, *ResourceConflictError) {
	list.Lock()

	list.idCounter++
	wgTask := &sync.WaitGroup{}
	task := NewTask(process, name, list.idCounter, resources, wgTask)

	list.tasks = append(list.tasks, task)
	list.wgTasks[task.ID] = wgTask

	list.wg.Add(1)
	task.wgTask.Add(1)

	// Copy task while still holding the lock to avoid racing with consumer
	// setting State=RUNNING after receiving from queue
	taskCopy := *task

	// add task to queue for processing if resources are available
	// if not, task will be queued by the consumer once resources are available
	tasks := list.usedResources.UsedBy(resources)
	if len(tasks) == 0 {
		list.usedResources.MarkInUse(task.Resources, task)
		// queueing task might block if channel not ready, unlock list before queueing
		list.Unlock()
		list.queue <- task
	} else {
		list.Unlock()
	}

	return taskCopy, nil
}

// Clear removes finished tasks from list
func (list *List) Clear() {