Method GetSnapshot

pkg/task/queue/queue_set.go:151–172

GetSnapshot returns a snapshot of all queues at the time of the call. This is useful for iteration when you need to call methods on the queues that might acquire locks, preventing deadlocks. The returned slice is a snapshot and will not reflect subsequent changes. The main queue (tqs.MainName) is a

()

// The returned slice is a snapshot and will not reflect subsequent changes.
// The main queue (tqs.MainName) is always placed first in the list.
func (tqs *TaskQueueSet) GetSnapshot() []*TaskQueue {
	tqs.logger.Debug("GetSnapshot: creating snapshot of queues")

	allQueues := tqs.Queues.List()
	queues := make([]*TaskQueue, 0, len(allQueues))

	// First, add the main queue if it exists
	if mainQueue := tqs.GetMain(); mainQueue != nil {
		queues = append(queues, mainQueue)
	}

	// Then add all other queues
	for _, queue := range allQueues {
		if queue.Name != tqs.MainName {
			queues = append(queues, queue)
		}
	}

	tqs.logger.Debug("GetSnapshot: creating snapshot of queues done")

	return queues
}

// IterateSnapshot creates a snapshot of all queues and iterates over the copy.
// This is safer than Iterate() when you need to call queue methods inside the callback,