Akatsuki-Misaki/ArchiSteamFarm
1
0
Fork 0
mirror of https://github.com/JustArchiNET/ArchiSteamFarm.git synced 2026-01-13 23:20:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

Misc

Browse Source
This commit is contained in:
JustArchi
2019-07-28 21:17:05 +02:00
parent 47aa0d03af
commit 214a6a68c7
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
ArchiSteamFarm/Collections/FixedSizeConcurrentQueue.cs
View File

@@ -26,7 +26,7 @@ using System.Collections.Generic;
namespace ArchiSteamFarm.Collections {
internal sealed class FixedSizeConcurrentQueue<T> : IEnumerable<T> {
private readonly ConcurrentQueue<T> Queue = new ConcurrentQueue<T>();
private readonly ConcurrentQueue<T> BackingQueue = new ConcurrentQueue<T>();
internal byte MaxCount {
get => BackingMaxCount;
@@ -40,7 +40,7 @@ namespace ArchiSteamFarm.Collections {
BackingMaxCount = value;
while ((Queue.Count > MaxCount) && Queue.TryDequeue(out _)) { }
while ((BackingQueue.Count > MaxCount) && BackingQueue.TryDequeue(out _)) { }
}
}
@@ -54,17 +54,17 @@ namespace ArchiSteamFarm.Collections {
MaxCount = maxCount;
}
public IEnumerator<T> GetEnumerator() => Queue.GetEnumerator();
public IEnumerator<T> GetEnumerator() => BackingQueue.GetEnumerator();
IEnumerator IEnumerable.GetEnumerator() => GetEnumerator();
internal void Enqueue(T obj) {
Queue.Enqueue(obj);
BackingQueue.Enqueue(obj);
if (Queue.Count <= MaxCount) {
if (BackingQueue.Count <= MaxCount) {
return;
}
Queue.TryDequeue(out _);
BackingQueue.TryDequeue(out _);
}
}
}