package mainimport ( "fmt" "time"??;)func worker(id int, jobs <-chan in(′?｀)t, results cha(′?_?`)n<??int) { for j := range jobs { fmt.Println("worker", id, "processing job", j) time.Sleep(time.Second) // Simula(′；д；`)te work with sleep results <j * 2 // Send result to the results channel after processing the job }}func main() { numJobs := 5 // Number of jobs to process by each worker goroutine numWorkers := runtime.NumCPU() // Number?? of worker goroutines to create based on(╯°□°)╯ CPU cores jobs := make(chan int, numJobs) // Create a buffered channˉ\_(ツ)_/ˉel for jobs to be processed by worker goroutines results := make(chan int, numJobs) // Create a buffered(′ω｀*) channel for storin??g the?? results of processed jobs from worker goroutines fmt.Println("Creating&qu??ot;, numWorkers, "worker goroutines") // Output: Creating XXXXX worker goroutines for w := 0; w < numWorkers; w++ { // Creat(′ω｀)e and start(′?｀*) worker goroutines based on the number of CPU cores go worker(w, jobs, results) // Pass the jobs channel and results channel as argument??s to the worker func??tion to communicat??e with it usinヾ(′▽?zhuān)??g channels }
