marion 5 年之前
父节点
当前提交
af4e9b0520
共有 1 个文件被更改,包括 2 次插入3 次删除
  1. 2 3
      utils/queue/buffer_postman.go

+ 2 - 3
utils/queue/buffer_postman.go

@@ -206,11 +206,10 @@ func (p *BufferPostman) deliver() {
 // 重置定时器
 func (p *BufferPostman) resetTimer() {
 	if nil != p.timer && p.duration > 0 {
-		if len(p.timer.C) > 0 {
+		if !p.timer.Stop() {
 			<-p.timer.C
 		}
-		p.timer = time.NewTimer(p.duration)
-		//p.timer.Reset(p.duration)
+		p.timer.Reset(p.duration)
 		p.isTimerStop = false
 	}
 }