Stop timer before flushing

1 year ago · b4880eee87
parent b923c73838
commit b4880eee87
1 changed files with 3 additions and 0 deletions
--- a/queue/queue.go
+++ b/queue/queue.go
@ -208,6 +208,9 @@ func (q *Queue) run() {
 			writeFn()
 		case <-q.flush:
 			stats.Add(numFlush, 1)
+			if !timer.Stop() {
+				<-timer.C
+			}
 			writeFn()
 		case <-q.done:
 			timer.Stop()