test

def.go

@@ -211,13 +211,17 @@ const (
 	objJobPriorityRescanChildMsg = 3
 	objJobPriorityRescanAllMsg   = 4
 
-	MQGetMsgWorkers       = 12
-	SQLCWMsgWorkers       = 6
-	SQLIdentifyMsgWorkers = 6
-	SQLJobWorkers         = 3
-	TGCmdWorkers          = 3
-	MQTGCmdWorkers        = 3
-	SQLJobSliceSize       = 25
+	MQGetMsgWorkers         = 12
+	MQCWMsgQueueSize        = 100
+	SQLCWMsgWorkers         = 6
+	SQLIdentifyMsgWorkers   = 6
+	SQLMsgIdentifyQueueSize = 1000
+	SQLJobWorkers           = 12
+	TGCmdWorkers            = 3
+	TGCmdQueueSize          = 100
+	MQTGCmdWorkers          = 3
+	MQTGCmdQueueSize        = 100
+	SQLJobSliceSize         = 250
 )
 
 var (

main.go

@@ -105,10 +105,10 @@ func main() {
 	}
 	b.Send(&u, "Bot restarted")
 
-	MQCWMsgQueue = make(chan ChatWarsMessage, 100)
-	SQLMsgIdentifyQueue = make(chan int64, 100)
-	TGCmdQueue = make(chan TGCommand, 100)
-	MQTGCmdQueue = make(chan TGCommand, 100)
+	MQCWMsgQueue = make(chan ChatWarsMessage, MQCWMsgQueueSize)
+	SQLMsgIdentifyQueue = make(chan int64, SQLMsgIdentifyQueueSize)
+	TGCmdQueue = make(chan TGCommand, TGCmdQueueSize)
+	MQTGCmdQueue = make(chan TGCommand, MQTGCmdQueueSize)
 	clientsQueue = make(map[int64]*MQClient)
 	clientsKeepAlive = make(map[int64]*MQKeepAlive)