Method IterateSnapshot

pkg/task/queue/task_queue.go:1048–1073

IterateSnapshot creates a snapshot of all tasks and iterates over the copy. This is safer than Iterate() when you need to call queue methods inside the callback, as no locks are held during callback execution. Note: The snapshot may become stale during iteration if tasks are added/removed by other

(doFn func(task.Task))

//
// Memory overhead: O(n) where n is the number of tasks in the queue.
func (q *TaskQueue) IterateSnapshot(doFn func(task.Task)) {
	if doFn == nil {
		return
	}

	defer q.MeasureActionTime("IterateSnapshot")()

	// Create snapshot under lock
	snapshot := q.GetSnapshot()

	defer func() {
		if r := recover(); r != nil {
			q.logger.Warn("panic recovered in TaskQueue IterateSnapshot",
				slog.Any(pkg.LogKeyError, r),
				slog.String(pkg.LogKeyStack, string(debug.Stack())),
				slog.String(pkg.LogKeyQueue, q.Name),
				slog.Int(pkg.LogKeyTasksCount, len(snapshot)),
			)
		}
	}()

	// Execute callbacks without holding any locks
	for _, t := range snapshot {
		doFn(t)
	}
}

// GetSnapshot returns a copy of all tasks in the queue.
// This is useful for external iteration or processing without holding locks.