Implementierung eines Worker-Pools zur parallelen Aufgabenverarbeitung

package main
 
import (
	"fmt"
	"sync"
)
 
func worker(id int, jobs <-chan int, results chan<- int, wg *sync.WaitGroup) {
	defer wg.Done()
	for job := range jobs {
		results <- job * 2
	}
}
 
func runWorkerPool(numWorkers int, numJobs int) []int {
	jobs := make(chan int, numJobs)
	results := make(chan int, numJobs)
	var wg sync.WaitGroup
 
	for w := 1; w <= numWorkers; w++ {
		wg.Add(1)
		go worker(w, jobs, results, &wg)
	}
 
	for j := 1; j <= numJobs; j++ {
		jobs <- j
	}
	close(jobs)
 
	wg.Wait()
	close(results)
 
	var output []int
	for res := range results {
		output = append(output, res)
	}
	return output
}