test

sm_upate_handler.go

@@ -2,12 +2,15 @@ package fusenrender
 
 import (
 	"context"
+	"log"
 
 	"github.com/474420502/execute/triggered"
 	"github.com/474420502/passer"
 	sm "github.com/lni/dragonboat/v4/statemachine"
 )
 
+var putCount int = 0
+
 // 结构体异步传递后, 执行的注册函数, 实际上就是update的handler
 var FsPasser *passer.Passer[sm.Result] = func() *passer.Passer[sm.Result] {
 
@@ -35,6 +38,9 @@ var FsPasser *passer.Passer[sm.Result] = func() *passer.Passer[sm.Result] {
 			Value: cmd.Item,
 		})
 
+		putCount++
+		log.Println("put", putCount)
+
 		var result sm.Result
 		dequeueHandler.Notify(dequeueHandler.NULL) // 通知可以执行update
 		return result, nil