diff --git a/VideoAnalysisCore/Common/RedisExpand.cs b/VideoAnalysisCore/Common/RedisExpand.cs index 615263a..63db622 100644 --- a/VideoAnalysisCore/Common/RedisExpand.cs +++ b/VideoAnalysisCore/Common/RedisExpand.cs @@ -230,14 +230,15 @@ namespace VideoAnalysisCore.Common InsertChannel(lastEnum, oldTask); return; } - + if (Subscribe?.IsUnsubscribed == false)//排除重试机制后 多次接收任务导致内存泄露 + return; Subscribe = Redis.SubscribeList(RedisExpandKey.ChannelKey, (taskId) => { if (taskId is null) return; Subscribe?.Dispose(); //存储当前机器的任务 Redis.Set(RedisExpandKey.IDTask, taskId); - Console.WriteLine(DateTime.Now.ToString("HH:mm:ss") + "-> 接收到任务 " + taskId); + Console.WriteLine(DateTime.Now.ToString("HH:mm:ss") + "-------------> 接收到任务 " + taskId); InsertChannel(RedisChannelEnum.DownloadFile, taskId); });