fusen/fusen-render
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

删掉垃圾数据

Browse Source
This commit is contained in:
eson 2023-11-13 23:29:32 +08:00
parent 68787ed426
commit fb96268d7e
2 changed files with 1 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
main.go
View File

@ -21,12 +21,10 @@ var shardID uint64 = 128
// 出队的逻辑注册触发函数, 当 // 出队的逻辑注册触发函数, 当
var DequeueHandler = triggered.RegisterExecute(func(params *triggered.Params[bool]) { var DequeueHandler = triggered.RegisterExecute(func(params *triggered.Params[bool]) {
log.Println("DequeueHandler 触发数据")
params.Shared.Value(func(v any) {
params.Shared.Value(func(v any) {
cs := stateClient.GetNoOPSession() cs := stateClient.GetNoOPSession()
for { for {
item, err := stateClient.PopItem(cs, "unity3d") item, err := stateClient.PopItem(cs, "unity3d")
if err != nil { if err != nil {
log.Println(err) log.Println(err)

1
start_test.go
View File

@ -6,7 +6,6 @@ import (
func init() { func init() {
log.SetFlags(log.Llongfile) log.SetFlags(log.Llongfile)
} }
// func TestStartNodeA(t *testing.T) { // func TestStartNodeA(t *testing.T) {