This commit is contained in:
DarthAffe committed 2017-08-26 17:47:59 +02:00
commit 43dd6968d9
1 file changed
+5 -1
@@ -204,6 +204,8 @@ namespace OBD.NET.Common.Devices
if (_queueSize == 0)
_queueEmptyEvent.Set();
try
{
if (_commandQueue.TryTake(out CurrentCommand, 10, _commandCancellationToken.Token))
{
_queueSize--;
@@ -219,6 +221,8 @@ namespace OBD.NET.Common.Devices
_commandFinishedEvent.WaitOne();
}
}
catch (OperationCanceledException) { /*ignore, because it is thrown when the cancellation token is canceled*/}
}
}
public void WaitQueue() => _queueEmptyEvent.WaitOne();
@@ -230,9 +234,9 @@ namespace OBD.NET.Common.Devices
/// </summary>
public virtual void Dispose()
{
_commandQueue.CompleteAdding();
_commandCancellationToken?.Cancel();
_commandWorkerTask?.Wait();
Connection?.Dispose();
}