fix: add timer stop to avoid leak (#487)

go-co-op · May 12, 2023 · 08fc015 · 08fc015
1 parent ac9c50d
commit 08fc015
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/executor.go b/executor.go
@@ -148,10 +148,12 @@ func (e *executor) runJob(f jobFunction) {
 					durationToNextRun = time.Second * 5
 				}
 				if durationToNextRun > time.Millisecond*100 {
-					timeToSleep := time.Duration(float64(durationToNextRun) * 0.9)
+					timer := time.NewTimer(time.Duration(float64(durationToNextRun) * 0.9))
+					defer timer.Stop()
+
 					select {
 					case <-e.ctx.Done():
-					case <-time.After(timeToSleep):
+					case <-timer.C:
 					}
 				}
 				_ = l.Unlock(f.ctx)