diff --git a/main.go b/main.go
index 644b4fcb0e5c8a38ece25e1e2a0e1136ab840688..c66bb21cc379505a5e8a4abb1ec7b256eac4752d 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()
 		}()