Fan-out example in Go

golang-fanout

package main

import "fmt"
import "bufio"
import "os"
import "strings"

var id int = 0

func WorkerProcess(in <-chan string) {
	id = id + 1
	thisId := id
	for {
		fmt.Printf("%d: waiting for input...\n", thisId)
		input := <-in
		fmt.Printf("%d: input is: %s\n", thisId, input)
	}
}

func main() {
	input := make(chan string)
	go WorkerProcess(input)
	go WorkerProcess(input)
	go WorkerProcess(input)
	reader := bufio.NewReader(os.Stdin)
	for {
		i, _ := reader.ReadString('\n')
		i = strings.TrimRight(i, "\n")
		input <- i
	}
}