记录协程数量

services/websocket_msg.go

@@ -6,6 +6,7 @@ import (
 	"eta/eta_api/services/data"
 	"eta/eta_api/utils"
 	"fmt"
+	"runtime"
 	"sync"
 	"time"
 
@@ -24,19 +25,19 @@ func DealEdbInspectionMessage(connKey string, conn *websocket.Conn, adminId int)
 	ctx, cancel := context.WithCancel(context.Background())
 	defer cancel()
 
-	// // 监控 goroutine 数量
+	// 监控 goroutine 数量
-	// go func() {
+	go func() {
-	// 	ticker := time.NewTicker(time.Minute)
+		ticker := time.NewTicker(time.Minute)
-	// 	defer ticker.Stop()
+		defer ticker.Stop()
-	// 	for {
+		for {
-	// 		select {
+			select {
-	// 		case <-ticker.C:
+			case <-ticker.C:
-	// 			utils.FileLog.Info("Current goroutine count: %d", runtime.NumGoroutine())
+				utils.FileLog.Info("Current goroutine count: %d", runtime.NumGoroutine())
-	// 		case <-ctx.Done():
+			case <-ctx.Done():
-	// 			return
+				return
-	// 		}
+			}
-	// 	}
+		}
-	// }()
+	}()
 
 	cacheKey := fmt.Sprintf("%s%d", utils.CACHE_EDB_INSPECTION_MESSAGE, adminId)