issue fix for timer.

pinealctx · Dec 4, 2021 · b3d6d26 · b3d6d26
1 parent 498a9a6
commit b3d6d26
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 5 deletions.
diff --git a/hookq/consumer.go b/hookq/consumer.go
@@ -122,14 +122,10 @@ func (c *Consumer) start() {
 			c.process()
 			if timer == nil {
 				timer = time.NewTimer(c.tick)
-			} else {
-				if !timer.Stop() {
-					<-timer.C
-				}
-				timer.Reset(c.tick)
 			}
 			select {
 			case <-timer.C:
+				timer.Reset(c.tick)
 			case <-c.stopChan:
 				c.submitWhenExit()
 				if !timer.Stop() {

diff --git a/hookq/example/consumer.go b/hookq/example/consumer.go
@@ -114,6 +114,7 @@ func consumerMsg(c *cli.Context) error {
 		signal.Notify(signalChan, syscall.SIGINT, syscall.SIGTERM)
 		select {
 		case <-signalChan:
+			log.Println("received.exit.ctrl-c")
 			consumer.Stop()
 			consumer.Wait()
 			log.Println("consumer.exit.by.signal")