SetLimit и границы errgroup

Лимит параллелизма

g, ctx := errgroup.WithContext(ctx)
g.SetLimit(8)

for _, f := range files {
    f := f
    g.Go(func() error {
        return upload(ctx, f)
    })
}

g.Wait()

С лимитом 8 одновременно работает не больше восьми функций. Остальные не «встают в очередь» — блокируется сама горутина, вызвавшая Go, до тех пор, пока не освободится слот. Внутри это обычный семафор на канале — та же техника, что в следующем уроке: Go отправляет токен, завершённая функция возвращает его.

Errgroup как пул

SetLimit превращает errgroup в лёгкий worker pool из: ограниченный параллелизм плюс готовый сбор ошибок и отмена по первому сбою. Для пачки однотипных задач это короче и безопаснее самописного пула с каналами и WaitGroup.

TryGo

Если блокироваться в Go не хочется, есть TryGo: при исчерпанном лимите он вернёт false, вместо того чтобы ждать. Удобно, когда лимит — это «сколько ещё можем принять», а не «сколько будем ждать».