From 6dd44fff53733e2b6cf835b47d7cc518a7871e8f Mon Sep 17 00:00:00 2001
From: eson <9673575+githubcontent@user.noreply.gitee.com>
Date: Tue, 14 Nov 2023 11:45:46 +0800
Subject: [PATCH] =?UTF-8?q?=E8=BE=93=E5=87=BA=E6=97=A5=E5=BF=97=E6=9B=B4?=
 =?UTF-8?q?=E5=8A=A0=E5=90=88=E7=90=86?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 sm.go        | 16 ++++++++--------
 websocket.go |  4 ++--
 2 files changed, 10 insertions(+), 10 deletions(-)

diff --git a/sm.go b/sm.go
index 6448be2..13f5abe 100644
--- a/sm.go
+++ b/sm.go
@@ -7,6 +7,7 @@ import (
 	"log"
 	"runtime"
 	"sync"
+	"time"
 
 	"github.com/474420502/execute/triggered"
 	sm "github.com/lni/dragonboat/v4/statemachine"
@@ -37,14 +38,13 @@ func NewSMQueue(shardID uint64, replicaID uint64) sm.IStateMachine {
 		queues: make(map[string]*PriorityQueue[QueueItem]),
 
 		counter: triggered.RegisterExecute[int64](func(params *triggered.Params[int64]) {
-			if params.Value != 0 {
-				var m runtime.MemStats
-				runtime.ReadMemStats(&m)
-				allocMB := float64(m.Alloc) / 1024 / 1024
-				// totalAllocMB := float64(m.TotalAlloc) / 1024 / 1024
-				sysMB := float64(m.Sys) / 1024 / 1024
-				log.Printf("队列堆积数据: %d, Alloc = %.2f MB, Sys = %.2fMB\n", params.Value, allocMB, sysMB)
-			}
+			var m runtime.MemStats
+			runtime.ReadMemStats(&m)
+			allocMB := float64(m.Alloc) / 1024 / 1024
+			// totalAllocMB := float64(m.TotalAlloc) / 1024 / 1024
+			sysMB := float64(m.Sys) / 1024 / 1024
+			log.Printf("队列堆积数据: %d, Alloc = %.2f MB, Sys = %.2fMB\n", params.Value, allocMB, sysMB)
+			time.Sleep(time.Second * 10) // 每超过10秒 统计一次
 		}),
 	}
 }
diff --git a/websocket.go b/websocket.go
index a9b22b6..70837bd 100644
--- a/websocket.go
+++ b/websocket.go
@@ -51,9 +51,9 @@ var countPutPop *CountPutPop = &CountPutPop{
 
 var logIntervalTimeHandler = triggered.RegisterExecute[*CountPutPop](func(params *triggered.Params[*CountPutPop]) {
 	params.Value.Use(func(item *CountPutPop) {
-		log.Printf("all pop: %d all put: %d\n", item.PutCount, item.PopCount)
+		log.Printf("all pop count: %d all put count: %d\n", item.PutCount, item.PopCount)
 		for k, v := range item.SelfCount {
-			log.Printf("%s pop: %d\n", k, v)
+			log.Printf("uinty3d[%s] pop count: %d\n", k, v)
 		}
 	})
 	time.Sleep(time.Second * 15)