From 298cef7f055d4e73d660f4596c6216a03f296871 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=88=98=E7=A5=A5=E8=B6=85?= Date: Wed, 18 May 2022 21:41:34 +0800 Subject: [PATCH] =?UTF-8?q?=E7=BC=A9=E7=9F=AD=E6=8C=87=E6=A0=87=E7=BB=9F?= =?UTF-8?q?=E8=AE=A1=E9=98=9F=E5=88=97=E9=95=BF=E5=BA=A6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/metrics/task.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/metrics/task.go b/internal/metrics/task.go index cae75c8..1bbd5ee 100644 --- a/internal/metrics/task.go +++ b/internal/metrics/task.go @@ -23,7 +23,7 @@ import ( "time" ) -const MaxQueueSize = 10240 +const MaxQueueSize = 2048 // Task 单个指标任务 // 数据库存储: @@ -58,7 +58,7 @@ type Task struct { timeMap map[string]zero.Zero // time => bool serverIdMapLocker sync.Mutex - statsMap map[string]*Stat + statsMap map[string]*Stat // 待写入队列,hash => *Stat statsLocker sync.Mutex statsTicker *utils.Ticker }