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())
 		}