甲醛影响战斗力

command.go

@@ -17,6 +17,7 @@ type CmdDequeue struct {
 
 type Command struct {
 	Group   string `json:"group"`
+	Version string `json:"version"`
 }
 
 // func (cmd *Command) Encode() ([]byte, error) {

main.go

@@ -22,10 +22,6 @@ func main() {
 
 }
 
-func init() {
-
-}
-
 var Consumption = triggered.RegisterExecute(func(params *triggered.Params[bool]) {
 
 	var nh *dragonboat.NodeHost
@@ -60,7 +56,7 @@ var Consumption = triggered.RegisterExecute(func(params *triggered.Params[bool])
 				sysMB := float64(m.Sys) / 1024 / 1024
 
 				fmt.Printf("dequeue count %d, Alloc = %.2f MB, TotalAlloc = %.2f MB, Sys = %.2f MB\n", i, allocMB, totalAllocMB, sysMB)
-				time.Sleep(time.Second * 10)
+				time.Sleep(time.Second * 5)
 				break
 			} else {
 				var item QueueItem

start_test.go

@@ -32,7 +32,7 @@ func TestStartNodeA(t *testing.T) {
 		// this goroutine makes a linearizable read every 10 second. it returns the
 		// Count value maintained in IStateMachine. see datastore.go for details.
 		cs := nh.GetNoOPSession(128)
-		ticker := time.NewTicker(10 * time.Millisecond)
+		ticker := time.NewTicker(1 * time.Millisecond)
 		for {
 			select {
 			case <-ticker.C:
@@ -87,7 +87,7 @@ func TestStartNodeB(t *testing.T) {
 		// Count value maintained in IStateMachine. see datastore.go for details.
 		cs := nh.GetNoOPSession(128)
 
-		ticker := time.NewTicker(10 * time.Millisecond)
+		ticker := time.NewTicker(1 * time.Millisecond)
 		for {
 			select {
 			case <-ticker.C: