marion 5 жил өмнө
parent
commit
9c92f6e962

+ 2 - 1
utils/queue/buffer_postman.go

@@ -209,7 +209,8 @@ func (p *BufferPostman) resetTimer() {
 		if len(p.timer.C) > 0 {
 			<-p.timer.C
 		}
-		p.timer.Reset(p.duration)
+		p.timer = time.NewTimer(p.duration)
+		//p.timer.Reset(p.duration)
 		p.isTimerStop = false
 	}
 }