We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 27638ea commit fdd8865Copy full SHA for fdd8865
1 file changed
retry_test.go
@@ -509,25 +509,23 @@ func TestNewThrottle(t *testing.T) {
509
th, reset := NewThrottle(10*time.Millisecond, f1)
510
511
is.Equal(0, callCount)
512
- for i := 0; i < 9; i++ {
513
- var wg sync.WaitGroup
514
- for j := 0; j < 100; j++ {
515
- wg.Add(1)
516
- go func() {
517
- defer wg.Done()
518
- th()
519
- }()
520
- }
521
- wg.Wait()
522
- time.Sleep(3 * time.Millisecond)
+ for j := 0; j < 100; j++ {
+ th()
523
}
524
- // 35 ms passed
525
- is.Equal(3, callCount)
+ is.Equal(1, callCount)
+
+ time.Sleep(15 * time.Millisecond)
+ }
+ is.Equal(2, callCount)
526
527
// reset counter
528
reset()
529
th()
530
- is.Equal(4, callCount)
+ is.Equal(3, callCount)
531
532
533
0 commit comments