No blocking channel based queue processor example

channel-processing-queue.go

package main

import (
	"fmt"
	"time"
)

func main() {
	queue := make(chan int, 5) // buffer up to 5 items to be processed
	done := make(chan bool)
	
	go func() {
		for n := range queue {
			time.Sleep(100 * time.Millisecond) // fake longer processing time
			fmt.Println(n)
		}
		fmt.Println("done processing")
		close(done) 
		
	}()
	
	for i := 0 ; i < 10; i++ {
		queue <- i // add items to be processed
	}
	fmt.Println("done queuing...")
	close(queue) // because this is closed, the range loop above will exit

	<- done // block until the queue is fully processed
}