Ответ
Worker Pool — это паттерн, где фиксированное количество горутин (workers) обрабатывает задачи из общего канала. Это позволяет ограничить параллелизм и избежать перегрузки системы.
Пример:
func worker(id int, jobs <-chan int, results chan<- int) {
for j := range jobs {
results <- j * 2 // обработка задачи
}
}
func main() {
jobs := make(chan int, 100)
results := make(chan int, 100)
// Создаем 3 воркера
for w := 1; w <= 3; w++ {
go worker(w, jobs, results)
}
// Отправляем задачи
for j := 1; j <= 5; j++ {
jobs <- j
}
close(jobs)
// Получаем результаты
for r := 1; r <= 5; r++ {
fmt.Println(<-results)
}
}
Преимущества:
- Контроль над количеством одновременно работающих горутин
- Эффективное использование ресурсов
- Упрощение управления задачами