懒得勤快 7 years ago
parent
commit
b64ab9123a

+ 0 - 35
Masuit.Tools.Core/Systems/LimitedConcurrentQueue.cs

@@ -1,35 +0,0 @@
-using System.Collections.Concurrent;
-using System.Collections.Generic;
-using System.Linq;
-
-namespace Masuit.Tools.Core.Systems
-{
-    /// <summary>
-    /// 定长队列
-    /// </summary>
-    /// <typeparam name="T"></typeparam>
-    public class LimitedConcurrentQueue<T> : ConcurrentQueue<T>
-    {
-        public int Limit { get; set; }
-
-        public LimitedConcurrentQueue(int limit)
-        {
-            Limit = limit;
-        }
-
-        public LimitedConcurrentQueue(IEnumerable<T> list) : base(list)
-        {
-            Limit = list.Count();
-        }
-
-        public new void Enqueue(T item)
-        {
-            if (Count >= Limit)
-            {
-                TryDequeue(out var _);
-            }
-
-            base.Enqueue(item);
-        }
-    }
-}

+ 1 - 1
Masuit.Tools/Masuit.Tools.csproj

@@ -113,7 +113,7 @@
     <Compile Include="Properties\AssemblyInfo.cs" />
     <Compile Include="Security\HashEncode.cs" />
     <Compile Include="Security\RSACrypt.cs" />
-    <Compile Include="Systems\LimitedConcurrentQueue.cs" />
+    <Compile Include="Systems\ConcurrentLimitedQueue.cs" />
     <Compile Include="Systems\LimitedQueue.cs" />
     <Compile Include="Strings\ValidateCode.cs" />
     <Compile Include="Net\WebExtension.cs" />

+ 3 - 3
Masuit.Tools/Systems/LimitedConcurrentQueue.cs → Masuit.Tools/Systems/ConcurrentLimitedQueue.cs

@@ -8,16 +8,16 @@ namespace Masuit.Tools.Systems
     /// 定长队列
     /// </summary>
     /// <typeparam name="T"></typeparam>
-    public class LimitedConcurrentQueue<T> : ConcurrentQueue<T>
+    public class ConcurrentLimitedQueue<T> : ConcurrentQueue<T>
     {
         public int Limit { get; set; }
 
-        public LimitedConcurrentQueue(int limit)
+        public ConcurrentLimitedQueue(int limit)
         {
             Limit = limit;
         }
 
-        public LimitedConcurrentQueue(IEnumerable<T> list) : base(list)
+        public ConcurrentLimitedQueue(IEnumerable<T> list) : base(list)
         {
             Limit = list.Count();
         }