Go by Example: Pool di Worker

In questo esempio vedremo come implementare un pool di worker usando goroutine e canali.
	`package main`
	`import ( "fmt" "time" )`
Ecco il worker, di cui eseguiremo diverse istanze concorrenti. Questi worker riceveranno lavoro dal canale `jobs` e invieranno i risultati corrispondenti su `results`. Aspetteremo un secondo per job per simulare un’operazione costosa.	`func worker(id int, jobs <-chan int, results chan<- int) { for j := range jobs { fmt.Println("worker", id, "started job", j) time.Sleep(time.Second) fmt.Println("worker", id, "finished job", j) results <- j * 2 } }`
	`func main() {`
Per utilizzare il nostro pool di worker dobbiamo inviare loro del lavoro e raccogliere i risultati. Creiamo 2 canali per questo.	`const numJobs = 5 jobs := make(chan int, numJobs) results := make(chan int, numJobs)`
Questo avvia 3 worker, inizialmente bloccati perché non ci sono ancora job.	`for w := 1; w <= 3; w++ { go worker(w, jobs, results) }`
Qui inviamo 5 `jobs` e poi chiudiamo quel canale per indicare che è tutto il lavoro che abbiamo.	`for j := 1; j <= numJobs; j++ { jobs <- j } close(jobs)`
Infine raccogliamo tutti i risultati del lavoro. Questo assicura anche che le goroutine worker abbiano terminato. Un modo alternativo per attendere più goroutine è utilizzare un WaitGroup.	`for a := 1; a <= numJobs; a++ { <-results } }`

Il nostro programma in esecuzione mostra i 5 job che vengono eseguiti da vari worker. Il programma impiega solo circa 2 secondi nonostante faccia circa 5 secondi di lavoro totale perché ci sono 3 worker che operano simultaneamente.

$ time go run pool-di-worker.go 
worker 1 started  job 1
worker 2 started  job 2
worker 3 started  job 3
worker 1 finished job 1
worker 1 started  job 4
worker 2 finished job 2
worker 2 started  job 5
worker 3 finished job 3
worker 1 finished job 4
worker 2 finished job 5

real    0m2.358s

Prossimo esempio: WaitGroup.

Go by Example: Pool di Worker 🌙

Go by Example: Pool di Worker