Как реализовать параллельную обработку с ограничением количества горутин?

В Go для ограничения числа одновременно выполняемых горутин часто используют семафор, реализованный через буферизированный канал (chan struct{}).

Принцип работы:

1. Создаём канал sema := make(chan struct{}, N) — где N это максимально допустимое количество одновременных горутин.

2. Перед запуском каждой горутины записываем пустую структуру в канал.

3. По завершению горутина читает из канала, освобождая слот.

Пример:

sema := make(chan struct{}, 10) // максимум 10 горутин

for _, task := range tasks {
    sema <- struct{}{}
    go func(task Task) {
        defer func() { <-sema }()
        process(task)
    }(task)
}

Этот подход:

• Лаконичен

• Безопасен

• Подходит для любых задач с ограничением по ресурсу (CPU, соединениям и т.д.)

Альтернатива — реализация через worker pool, где фиксированное количество воркеров получают задания через канал.