zydronium/SMBLibrary
1
0
Fork 0
mirror of https://github.com/TalAloni/SMBLibrary.git synced 2025-08-11 01:49:18 +02:00
Code Issues Projects Releases Packages Wiki Activity

Utilities: BlockingQueue.TryDequeue: Change behavior to return all items enqueued before Stop was invoked

Browse source
This commit is contained in:
Tal Aloni 2025-05-01 21:37:48 +03:00
parent 21313ac030
commit a9ec1878d0
1 changed files with 17 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

19
Utilities/Generics/BlockingQueue.cs
View file

@ -17,6 +17,11 @@ namespace Utilities
public void Enqueue(T item) public void Enqueue(T item)
{ {
if (m_stopping)
{
return;
}
lock (m_queue) lock (m_queue)
{ {
m_queue.Enqueue(item); m_queue.Enqueue(item);
@ -30,10 +35,11 @@ namespace Utilities
public void Enqueue(List<T> items) public void Enqueue(List<T> items)
{ {
if (items.Count == 0) if (m_stopping || items.Count == 0)
{ {
return; return;
} }
lock (m_queue) lock (m_queue)
{ {
foreach (T item in items) foreach (T item in items)
@ -60,7 +66,7 @@ namespace Utilities
Monitor.Wait(m_queue); Monitor.Wait(m_queue);
} }
if (m_stopping) if (m_stopping && m_queue.Count == 0)
{ {
item = default(T); item = default(T);
return false; return false;
@ -82,6 +88,15 @@ namespace Utilities
} }
} }
public void Abort()
{
lock (m_queue)
{
m_queue.Clear();
Stop();
}
}
public int Count public int Count
{ {
get get