feat:4个进程处理

cron/mic_cron/on_mic.go

@@ -47,24 +47,26 @@ func OnMicCheck() {
 }
 
 func OnMicQueue() {
-	go func() {
-		for true {
-			model := domain.CreateModelNil()
-			if onMic := mic_c.BLPopQueueOnMic(model); onMic != nil {
-				// 群组上麦经验
-				if err := group_mic_s.NewGroupPowerService(model.MyContext).IncrGroupPowerOnMicExpAndTime(onMic.GroupUuid, onMic.UserId, onMic.Timestamp); err != nil {
-					model.Log.Errorf("cron micIn GroupPowerOnMicExp err:%v", err)
-				} else {
-					model.Log.Infof("cron micIn GroupPowerOnMicExp success, groupId:%v, userId:%v", onMic.GroupUuid, onMic.UserId)
-				}
+	for i := 0; i < 4; i++ {
+		go func() {
+			for true {
+				model := domain.CreateModelNil()
+				if onMic := mic_c.BLPopQueueOnMic(model); onMic != nil {
+					// 群组上麦经验
+					if err := group_mic_s.NewGroupPowerService(model.MyContext).IncrGroupPowerOnMicExpAndTime(onMic.GroupUuid, onMic.UserId, onMic.Timestamp); err != nil {
+						model.Log.Errorf("cron micIn GroupPowerOnMicExp err:%v", err)
+					} else {
+						model.Log.Infof("cron micIn GroupPowerOnMicExp success, groupId:%v, userId:%v", onMic.GroupUuid, onMic.UserId)
+					}
 
-				// 用户上麦
-				//if err := mic_m.IncrUserOnMic(model, onMic.UserId, onMic.Timestamp); err != nil {
-				//	model.Log.Errorf("cron micIn IncrUserOnMic err:%v", err)
-				//} else {
-				//	model.Log.Infof("cron micIn IncrUserOnMic success,userId:%v", onMic.UserId)
-				//}
+					// 用户上麦
+					//if err := mic_m.IncrUserOnMic(model, onMic.UserId, onMic.Timestamp); err != nil {
+					//	model.Log.Errorf("cron micIn IncrUserOnMic err:%v", err)
+					//} else {
+					//	model.Log.Infof("cron micIn IncrUserOnMic success,userId:%v", onMic.UserId)
+					//}
+				}
 			}
-		}
-	}()
+		}()
+	}
 }