Параллельное выполнение и передача контекста между агентами

// runParallel запускает независимые подзадачи параллельно и собирает результаты.
func runParallel(ctx context.Context, tasks []string, sub SubAgent) ([]string, error) {
    results := make([]string, len(tasks)) // каждая горутина пишет в свою ячейку
    errs := make([]error, len(tasks))

    sem := make(chan struct{}, 4) // ограничиваем параллелизм (rate limit)
    var wg sync.WaitGroup

    for i, task := range tasks {
        wg.Add(1)
        go func(i int, task string) {
            defer wg.Done()
            select {
            case sem <- struct{}{}:
                defer func() { <-sem }()
            case <-ctx.Done():
                errs[i] = ctx.Err()
                return
            }
            results[i], errs[i] = sub(task) // sub должен уважать ctx внутри
        }(i, task)
    }
    wg.Wait()

    for _, err := range errs {
        if err != nil {
            return results, err // политика: вернуть первую ошибку (можно собирать частичное)
        }
    }
    return results, nil
}