From 5ed53ff4adfd136920b1144af740f13e06fc813c Mon Sep 17 00:00:00 2001 From: hujiebin Date: Fri, 8 Dec 2023 12:07:16 +0800 Subject: [PATCH] Revert "Update main.go" This reverts commit ca398e117622d17577da77682a5177460aec6877. --- main.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/main.go b/main.go index 644b4fc..c66bb21 100644 --- a/main.go +++ b/main.go @@ -13,7 +13,7 @@ import ( "time" ) -const SEND_WORKER = 1 // 消费端协程数量 todo for test +const SEND_WORKER = 2000 // 消费端协程数量 const MONITOR_LENGTH = 100 // 队列告警数量 var sendChan chan GroupSystemMsg @@ -25,7 +25,7 @@ func main() { mylogrus.MyLog.Infof("cron micChangeSys start") // 8核 n send + 4 blpop sendChan = make(chan GroupSystemMsg, SEND_WORKER) - for i := 0; i < 1; i++ { // todo for test + for i := 0; i < 4; i++ { go func() { deal() }() -- 2.22.0