package stm import ( "flag" "time" "sync" ) var nFlag = flag.Int( "n", 1_000, "The number of iterations to execute", ) func MainTest() { flag.Parse() n := *nFlag var wg sync.WaitGroup wg.Add(n) lim := NewLimiter(Every(1*time.Second), 1) for i := 0; i < n; i++ { go func() { lim.AllowN(1) wg.Done() }() } wg.Wait() }