Commit 5ed53ff4 authored by hujiebin's avatar hujiebin

Revert "Update main.go"

This reverts commit ca398e11.
parent ca398e11
...@@ -13,7 +13,7 @@ import ( ...@@ -13,7 +13,7 @@ import (
"time" "time"
) )
const SEND_WORKER = 1 // 消费端协程数量 todo for test const SEND_WORKER = 2000 // 消费端协程数量
const MONITOR_LENGTH = 100 // 队列告警数量 const MONITOR_LENGTH = 100 // 队列告警数量
var sendChan chan GroupSystemMsg var sendChan chan GroupSystemMsg
...@@ -25,7 +25,7 @@ func main() { ...@@ -25,7 +25,7 @@ func main() {
mylogrus.MyLog.Infof("cron micChangeSys start") mylogrus.MyLog.Infof("cron micChangeSys start")
// 8核 n send + 4 blpop // 8核 n send + 4 blpop
sendChan = make(chan GroupSystemMsg, SEND_WORKER) sendChan = make(chan GroupSystemMsg, SEND_WORKER)
for i := 0; i < 1; i++ { // todo for test for i := 0; i < 4; i++ {
go func() { go func() {
deal() deal()
}() }()
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment