package main

import (
        "log"
        "sync"
        "sync/atomic"
        "time"

        "golang.org/x/time/rate"
)

func main() {
        var limitCount = 1000
        var count int32
        threads := 200
        stdLimiter := rate.NewLimiter(rate.Limit(limitCount), limitCount)
        var wg sync.WaitGroup

        startgs := func(threads int) {
                start := time.Now()
                for i := 0; i < threads; i++ {
                        go func() {
                                defer wg.Done()
                                for {
                                        if time.Since(start) > time.Second {
                                                return
                                        }
                                        if stdLimiter.Allow() {
                                                atomic.AddInt32(&count, 1)
                                        }
                                }
                        }()
                }
        }
        wg.Add(threads)
        startgs(threads)
        wg.Wait()
        if atomic.LoadInt32(&count) > int32(3*limitCount) {
                log.Fatalf("fail, unexpected count: %d \n", count)
        } else {
                log.Println("success")
        }
}