Go Limit

Limit the maximum number of goroutines running at the same time.

Install

$ go get -u github.com/lenaten/go-limit

Usage

package main

import (
	"fmt"
	"time"

	"github.com/lenaten/go-limit"
)

func main() {
	max := 5
	l := golimit.New(max)

	for i := 1; i <= max*2; i++ {
		// Increment the GoLimit counter and wait for their turn.
		l.Add(1)
		go func(i int) {
			// Decrement the counter when the goroutine completes.
			defer l.Done()
			// Do some work.
			time.Sleep(time.Millisecond * time.Duration(i) * 200)
			fmt.Println(i)
		}(i)
	}
	// Wait for all functions to complete.
	l.Wait()
}