simple throttling of work in go

throttling.go

package main

import (
	"fmt"
	"time"
)

func main() {
	// queue of size 10
	queue := make(chan string, 10)
	
	// generate some data over time
	go func() {
		time.Sleep(time.Second * 3)
		for i := 0; i < 4; i++ {
			queue<- fmt.Sprintf("Item #%d", i)
		}

		time.Sleep(time.Second * 7)
		for i := 0; i < 10; i++ {
			queue<- fmt.Sprintf("Item #%d", i)
		}
	}()
	
	throttle := time.Tick(time.Second)
	for {
		fmt.Println("Tick")
		<-throttle // rate limit
		fmt.Println("Work! ", <-queue, time.Now())
		
		// channel selector will reset the throttle to prevent if firing twice in a row
		select {
			case <-throttle:
			default:
		}
	}
}