Dynamic Input Channels

gistfile1.go

package main

import (
    "fmt"                                                                                             
    "math"
    "time" 
)   
    
func main() {
    producerA := producer(1)
    producerB := producer(10)
    consumerA := consumer("A")
    consumerB := consumer("B")

    i := 0.0
    for {
        if math.Mod(i, 2) == 0.0 {
            consumerA <- producerA
            consumerB <- producerB
        } else {
            consumerA <- producerB
            consumerB <- producerA
        }
        time.Sleep(10e9)
        i++
    }
}

func producer(f int) chan int {
    c := make(chan int, 10)

    go func() {
        i := 0
        for {
            c <- i * f
            time.Sleep(1e9)
            i++
        }
    }()
    return c
}

func consumer(s string) chan chan int {
    from := make(chan chan int)
    var input chan int

    go func() {
        for {
            select {
            case input = <-from:
            case i := <-input:
                fmt.Printf("%v:%v\n", s, i)
            }
        }
    }()

    return from

}