rate

Rate Limiter

quick start

qps := 100
r := rate.NewRate(qps)
go r.Run()

go func() {
	qpsChan := r.QPS()
	for {
		select {
		case qps := <-qpsChan:
			println("QPS", qps)
		}
	}
}()

wg := sync.WaitGroup{}
count := 0
num := 100000

for i := 0; i < num; i++ {
	time.Sleep(5 * time.Millisecond)
	wg.Add(1)
	go func(j int) {
		defer wg.Done()
		if r.GetToken() {
			count++
		}
	}(i)
}

wg.Wait()
println("count", count)