合并代码

TEAMModelFunction/MonitorServicesBus.cs

@@ -166,18 +166,21 @@ namespace TEAMModelFunction
                     if (!exist)
                     {   ///key不存在则正常进行计算
                         bool condition = false;
-                        while (condition || !exist)
-                        {
-                            TimeSpan timeSpan = new TimeSpan(DateTimeOffset.UtcNow.AddMinutes(5).Ticks);
-                            //准备处理Blob刷新时间
-                            long action = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
-                            await _azureRedis.GetRedisClient(8).StringSetAsync(lockKey, action, expiry: timeSpan);
-                            await RefreshBlob(name, u);
-                            //将action 与Redis最新的时间进行比较，如果
-                            var rds =await CheckLockKey(lockKey, action);
-                            condition = rds.condition;
-                            exist = rds.exist;
-                        }
+                        TimeSpan timeSpan = new TimeSpan(DateTimeOffset.UtcNow.AddMinutes(5).Ticks);
+                        //准备处理Blob刷新时间
+                        long action = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
+                        await _azureRedis.GetRedisClient(8).StringSetAsync(lockKey, action, expiry: timeSpan);
+                        await RefreshBlob(name, u);
+                        //将action 与Redis最新的时间进行比较，如果
+                        var rds = await CheckLockKey(lockKey, action);
+                        condition = rds.condition;
+                        exist = rds.exist;
+                        await RefreshBlob(name, u);
+                        //使用  CancellationToken 
+                        //while (condition || !exist)
+                        //{
+
+                        //}
                     }
                     else {
                         ///key存在则,则刷新key对应的值

TEAMModelOS.SDK/DI/AzureStorage/AzureStorageBlobExtensions.cs

@@ -30,7 +30,6 @@ namespace TEAMModelOS.SDK.DI
             long? size = 0;
             try
             {
-               
                 await foreach (BlobItem item in client.GetBlobsAsync(BlobTraits.None, BlobStates.None, prefix))
                 {
                     size += item.Properties.ContentLength;