pepperdash/Essentials
1
0
Fork 0
mirror of https://github.com/PepperDash/Essentials.git synced 2026-04-13 12:37:07 +00:00
Code Issues Projects Releases Packages Wiki Activity

Merge 2feec62052 into 3a4737b6f6

Browse source
This commit is contained in:
Neil Dorin 2021-03-31 22:35:43 +00:00 • committed by GitHub
commit ce7f458239
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 16 additions and 12 deletions
Download patch file Download diff file Expand all files Collapse all files

28
essentials-framework/Essentials Core/PepperDashEssentialsBase/Queues/GenericQueue.cs
View file

@ -150,13 +150,13 @@ namespace PepperDash.Essentials.Core.Queues
_delayEnabled = pacing > 0; _delayEnabled = pacing > 0;
_delayTime = pacing; _delayTime = pacing;
CrestronEnvironment.ProgramStatusEventHandler += programEvent => //CrestronEnvironment.ProgramStatusEventHandler += programEvent =>
{ //{
if (programEvent != eProgramStatusEventType.Stopping) // if (programEvent != eProgramStatusEventType.Stopping)
return; // return;
Dispose(); // Dispose(true);
}; //};
} }
/// <summary> /// <summary>
@ -231,6 +231,8 @@ namespace PepperDash.Essentials.Core.Queues
if (disposing) if (disposing)
{ {
Debug.Console(2, this, "Disposing...");
_queue.Clear();
Enqueue(null); Enqueue(null);
_worker.Join(); _worker.Join();
_waitHandle.Close(); _waitHandle.Close();
@ -402,13 +404,13 @@ namespace PepperDash_Essentials_Core.Queues
_delayEnabled = pacing > 0; _delayEnabled = pacing > 0;
_delayTime = pacing; _delayTime = pacing;
CrestronEnvironment.ProgramStatusEventHandler += programEvent => //CrestronEnvironment.ProgramStatusEventHandler += programEvent =>
{ //{
if (programEvent != eProgramStatusEventType.Stopping) // if (programEvent != eProgramStatusEventType.Stopping)
return; // return;
Dispose(); // Dispose(true);
}; //};
} }
/// <summary> /// <summary>
@ -477,6 +479,8 @@ namespace PepperDash_Essentials_Core.Queues
if (disposing) if (disposing)
{ {
Debug.Console(2, this, "Disposing...");
_queue.Clear();
Enqueue(null); Enqueue(null);
_worker.Join(); _worker.Join();
_waitHandle.Close(); _waitHandle.Close();