concurent pipeline processing in go

pipeline.go

package main

import (
	"log"
	"strconv"
	"time"
)

var _ = log.Print

func genWork(queue chan int, sig chan bool) {

	for i := 0; i < 10; i++ {
		log.Print("q " + strconv.FormatInt(int64(i), 10))
		queue <- i
	}
	close(queue)
	sig <- true
}

func doWork(queue chan int, sig chan bool) {
	time.Sleep(1000 * time.Millisecond)

	for val := range queue {
		log.Print("d " + strconv.FormatInt(int64(val), 10))
	}

	log.Print("done working")
	sig <- true
}

func main() {
	queue := make(chan int, 20)

	genSig := make(chan bool, 1)
	doSig := make(chan bool, 1)

	go genWork(queue, genSig)
	go doWork(queue, doSig)

	log.Print("outer")

	<-genSig
	<-doSig

}