gistfile1.go

package main

import "time"
import "fmt"
import "sync"

func processThink(n int, workChan chan<- int) {
	time.Sleep(time.Duration(n) * time.Second)
	workChan <- n
}

func main() {
	workQueue := []int{8, 4, 1, 3, 5, 7, 9}
	inWorkChan := make(chan int)
	outWorkChan := make(chan int)

	var wg sync.WaitGroup
	for i := 0; i < 4; i++ {
		go func() {
			wg.Add(1)
			defer wg.Done()
			for n := range inWorkChan {
				processThink(n, outWorkChan)
			}
		}()
	}

	go func() {
		for _, work := range workQueue {
			inWorkChan <- work
		}
		close(inWorkChan)
		wg.Wait()
		close(outWorkChan)
	}()

	for n := range outWorkChan {
		fmt.Printf("%q Hey I finished %d\n", time.Now(), n)
	}
}