diff --git a/util/timewheel/timewheel.go b/util/timewheel/timewheel.go index b2e9402..d30de7d 100644 --- a/util/timewheel/timewheel.go +++ b/util/timewheel/timewheel.go @@ -258,6 +258,10 @@ func (t *timeWheel) newTimer(ticks int64,additionData interface{},c chan *Timer) pTimer.bClose = false pTimer.C = c pTimer.AdditionData = additionData + + if ticks<=0 { + ticks = 1 + } pTimer.expireTicks = ticks+t.currentTicks return pTimer }