diff --git a/cmd/peakHandling.go b/cmd/peakHandling.go index 870f7e7..eb98191 100644 --- a/cmd/peakHandling.go +++ b/cmd/peakHandling.go @@ -61,8 +61,9 @@ func prefetchPeakRequests(peakRequestMap *sync.Map) { } sleepBetweenRequests := time.Duration(prefetchInterval*1000/peakRequestLen) * time.Millisecond peakRequestMap.Range(func(key interface{}, value interface{}) bool { - r := value.(http.Request) - prefetchRequest(&r) + go func(r http.Request) { + prefetchRequest(&r) + }(value.(http.Request)) peakRequestMap.Delete(key) time.Sleep(sleepBetweenRequests) return true