chan_of_chan.go

package main

import (
	"fmt"
	"time"
)

// Worker function that listens for a job on its own channel
func worker(id int, jobChannel chan int) {
	for job := range jobChannel {
		fmt.Printf("Worker %d processing job %d\n", id, job)
		time.Sleep(time.Second) // Simulate work
	}
}

func main() {
	workerPool := make(chan chan int, 2) // Channel of job channels

	// Creating two workers with their own channels
	for i := 1; i <= 2; i++ {
		jobChannel := make(chan int) // Each worker gets a job channel
		workerPool <- jobChannel     // Register worker's channel in the pool
		go worker(i, jobChannel)     // Start worker goroutine
	}

	// Dispatcher sends jobs
	for j := 101; j <= 103; j++ {
		jobChannel := <-workerPool // Get a worker's channel
		fmt.Println("Dispatching job", j)
		jobChannel <- j          // Send job to worker
		workerPool <- jobChannel // Put worker back in the pool
	}

	// Give time for workers to process before exiting
	time.Sleep(3 * time.Second)
}