diff --git a/def.go b/def.go index 1c070db..fa0986f 100644 --- a/def.go +++ b/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 ( diff --git a/main.go b/main.go index b02c8ec..e558637 100644 --- a/main.go +++ b/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)