Sobes.tech
Back to questions
Senior
4

Ты хочешь классический worker pool писать?

Companies where asked
Cloud.ru

Answer from AI

sobes.tech AI

Да, классический worker pool — это паттерн для управления ограниченным числом параллельных задач. В Go его обычно реализуют с помощью горутин и каналов.

Идея в том, что есть пул воркеров (горутин), которые читают задачи из канала и обрабатывают их. Это позволяет контролировать количество одновременно выполняемых задач и эффективно использовать ресурсы.

Пример простого worker pool на Go:

package main

import (
	"fmt"
	"sync"
)

func worker(id int, jobs <-chan int, wg *sync.WaitGroup) {
	defer wg.Done()
	for j := range jobs {
		fmt.Printf("Worker %d processing job %d\n", id, j)
	}
}

func main() {
	jobs := make(chan int, 5)
	var wg sync.WaitGroup

	// Запускаем 3 воркера
	for w := 1; w <= 3; w++ {
		wg.Add(1)
		go worker(w, jobs, &wg)
	}

	// Отправляем 5 задач
	for j := 1; j <= 5; j++ {
		jobs <- j
	}
	close(jobs)

	wg.Wait()
}

Такой подход позволяет эффективно распределять задачи между ограниченным числом воркеров.