Method Push

internal/engine/concurrent/task_queue.go:28–34

(t types.Task)

}

func (q *TaskQueue) Push(t types.Task) {
	q.mu.Lock()
	q.tasks = append(q.tasks, t)
	q.size.Add(1)
	q.signalWaitingWorkersLocked(1)
	q.mu.Unlock()
}

func (q *TaskQueue) PushMultiple(tasks []types.Task) {
	if len(tasks) == 0 {