Update main.go

main.go

@@ -13,7 +13,7 @@ import (
 	"time"
 )
 
-const SEND_WORKER = 2000   // 消费端协程数量
+const SEND_WORKER = 1      // 消费端协程数量 todo for test
 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 < 4; i++ {
+	for i := 0; i < 1; i++ { // todo for test
 		go func() {
 			deal()
 		}()