From e1162c6a477131ad41d8ff3c889d26f447279a2c Mon Sep 17 00:00:00 2001
From: eson <474420502@qq.com>
Date: Mon, 13 Nov 2023 22:46:05 +0800
Subject: [PATCH] fix

---
 main.go             | 1 +
 sm_upate_handler.go | 4 +---
 2 files changed, 2 insertions(+), 3 deletions(-)

diff --git a/main.go b/main.go
index 8b66b0a..735d6b6 100644
--- a/main.go
+++ b/main.go
@@ -141,6 +141,7 @@ func StartNode(cfg *ConfigServer) {
 	go func() {
 		for DequeueHandler != nil {
 			DequeueHandler.Notify(DequeueHandler.NULL)
+			log.Println("DequeueHandler 触发")
 			time.Sleep(time.Second * 5)
 		}
 	}()
diff --git a/sm_upate_handler.go b/sm_upate_handler.go
index 192186e..9206a1e 100644
--- a/sm_upate_handler.go
+++ b/sm_upate_handler.go
@@ -80,9 +80,7 @@ var FsPasser *passer.Passer[sm.Result] = func() *passer.Passer[sm.Result] {
 			e.Result.Data = d
 			result.Data = d
 
-			if !queue.Empty() {
-				smqueue.counter.Notify(queue.Size())
-			}
+			smqueue.counter.Notify(queue.Size())
 
 			// log.Println("queue remain:", queue.Size())
 		}