pipeline_example.go

package main

import (
	"fmt"
	"time"
)

func main() {
	ints := []int{}

	n := 10
	for x := 0; x < n; x++ {
		ints = append(ints, x+1)
	}

	intsChan := makePipeline(ints)

	start := time.Now()
	for cnt := 0; cnt < len(ints); cnt++ {
		i := <-intsChan
		fmt.Print(i, " ")
	}
	fmt.Println("Elapsed: ", time.Since(start))
}

func makePipeline(ints []int) <-chan int {
	intsChan := make(chan int)

	go func() {
		for _, i := range ints {

			go func(i int) {
				intsChan <- mul(i)
			}(i)

		}
	}()

	return intsChan
}

func mul(i int) int {
	return i * i
}