fix: fix timewheel

Gleiphir2769 · Jan 30, 2023 · 5b976f7 · 5b976f7
1 parent ffb6bc3
commit 5b976f7
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/timewheel/timewheel.go b/timewheel/timewheel.go
@@ -148,8 +148,8 @@ func (tw *TimeWheel) addTask(task *task) {
 func (tw *TimeWheel) getPositionAndCircle(d time.Duration) (pos int, circle int) {
 	delaySeconds := int(d.Milliseconds())
 	intervalSeconds := int(tw.interval.Milliseconds())
-	circle = int(delaySeconds / intervalSeconds / tw.slotNum)
-	pos = int(tw.currentPos+delaySeconds/intervalSeconds-1) % tw.slotNum
+	circle = delaySeconds / intervalSeconds / tw.slotNum
+	pos = (tw.currentPos + delaySeconds/intervalSeconds) % tw.slotNum
 	if pos < 0 {
 		pos = 0
 	}