add randomness

Signed-off-by: Hagar Meir <[email protected]>

Author: HagarMeir

request/pool.go

@@ -9,6 +9,7 @@ package request
 import (
 	"context"
 	"fmt"
+	"math/rand"
 	"sync"
 	"sync/atomic"
 	"time"
@@ -101,7 +102,7 @@ func (rp *Pool) createPendingStore() *PendingStore {
 		OnDelete: func(key string) {
 			rp.semaphore.Release(1)
 		},
-		Epoch:                rp.options.FirstStrikeThreshold / 10,
+		Epoch:                time.Duration(rand.Intn(50))*time.Millisecond + rp.options.FirstStrikeThreshold/10,
 		FirstStrikeCallback:  rp.striker.OnFirstStrikeTimeout,
 		SecondStrikeCallback: rp.striker.OnSecondStrikeTimeout,
 	}