新测试

main.go

@@ -9,6 +9,7 @@ import (
 	"path/filepath"
 	"runtime"
 	"syscall"
+	"time"
 
 	"github.com/474420502/execute/triggered"
 	"github.com/lni/dragonboat/v4"
@@ -31,6 +32,7 @@ var DequeueHandler = triggered.RegisterExecute(func(params *triggered.Params[boo
 				break
 			}
 			if item == nil {
+				time.Sleep(time.Millisecond * 100)
 				return
 			}
 

sm_upate_handler.go

@@ -12,6 +12,7 @@ import (
 var FsPasser *passer.Passer[sm.Result] = func() *passer.Passer[sm.Result] {
 
 	fsPasser := passer.NewPasser[sm.Result]()
+
 	fsPasser.RegisterPasser(&CmdEnqueue{}, func(cxt context.Context, obj any) (sm.Result, error) {
 
 		var smqueue = cxt.Value(ctxSMQueue{}).(*SMQueue)

websocket_test.go

@@ -38,8 +38,9 @@ func TestWebsocketC(t *testing.T) {
 	fusenrender.StartNode(svc)
 }
 
-// var addr = "api.fusen.3718.cn:4050"
-var addr = "localhost:4050"
+var addr = "api.fusen.3718.cn:4050"
+
+// var addr = "localhost:4050"
 
 func TestWebsocketCient(t *testing.T) {
 	// u := url.URL{Scheme: "ws", Host: addr, Path: "/ws/pop/queue"}