Update forwarder to use time.Timer

hibiken · Apr 11, 2022 · 088be63 · 088be63
1 parent ed69667
commit 088be63
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/forwarder.go b/forwarder.go
@@ -56,13 +56,15 @@ func (f *forwarder) start(wg *sync.WaitGroup) {
 	wg.Add(1)
 	go func() {
 		defer wg.Done()
+		timer := time.NewTimer(f.avgInterval)
 		for {
 			select {
 			case <-f.done:
 				f.logger.Debug("Forwarder done")
 				return
-			case <-time.After(f.avgInterval):
+			case <-timer.C:
 				f.exec()
+				timer.Reset(f.avgInterval)
 			}
 		}
 	}()