fix:修正内存溢出的情况

This commit is contained in:
samwaf
2023-11-02 13:46:29 +08:00
parent 0b1ae5cda4
commit ec2df7183a

View File

@@ -28,12 +28,7 @@ func InitDequeEngine() {
*/
func ProcessDequeEngine() {
for {
defer func() {
e := recover()
if e != nil {
zlog.Info("ProcessErrorException", e)
}
}()
for !global.GQEQUE_DB.Empty() {
weblogbean := global.GQEQUE_DB.PopFront()
if weblogbean != nil {