SabreTools/MPF
1
0
Fork 0
mirror of https://github.com/SabreTools/MPF.git synced 2026-07-02 17:24:48 +00:00
Code Issues 392 Packages Projects Releases 20 Wiki Activity

Only rely on cancellation not disposal

Browse Source
This commit is contained in:
Matt Nadareski
2021-04-01 15:10:43 -07:00
parent 10f2318541
commit 54e835687b
1 changed files with 3 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
MPF.Library/Data/ProcessingQueue.cs
View File

@@ -17,11 +17,6 @@ namespace MPF.Data
/// </summary>
private readonly Action<T> CustomProcessing;
/// <summary>
/// Internal processing task for dequeueing
/// </summary>
private readonly Task ProcessingTask;
/// <summary>
/// Cancellation method for the processing task
/// </summary>
@@ -32,7 +27,7 @@ namespace MPF.Data
this.InternalQueue = new ConcurrentQueue<T>();
this.CustomProcessing = customProcessing;
this.TokenSource = new CancellationTokenSource();
this.ProcessingTask = Task.Run(() => ProcessQueue(), this.TokenSource.Token);
Task.Run(() => ProcessQueue(), this.TokenSource.Token);
}
/// <summary>
@@ -41,8 +36,6 @@ namespace MPF.Data
public void Dispose()
{
this.TokenSource.Cancel();
while (!this.ProcessingTask.IsCompleted) ;
this.ProcessingTask.Dispose();
}
/// <summary>
@@ -51,7 +44,8 @@ namespace MPF.Data
/// <param name="item"></param>
public void Enqueue(T item)
{
this.InternalQueue.Enqueue(item);
if (!this.TokenSource.IsCancellationRequested)
this.InternalQueue.Enqueue(item);
}
/// <summary>