Golang Rate limiting Concurrent Queue Worker Example

Golang Rate limiting Concurrent Queue Worker Example.md

package main

import (
	"fmt"
	"time"
)

func main() {
	concurrency := 2
	sem := make(chan bool, concurrency)
	var urls []string
	for i := 1; i <= 100; i++ {
		urls = append(urls, fmt.Sprintf("url-%v", i))
	}
	for _, url := range urls {
		sem <- true
		go func(url string) {
			defer func() { <-sem }()
			
			// do work son!
			time.Sleep(100 * time.Millisecond)
			fmt.Println(url)
		}(url)
	}
	for i := 0; i < cap(sem); i++ {
		sem <- true // fill up to queue cap
	}
	close(sem)
}