Гарантия System.Timers.Timer завершен ⇐ C#

[Anonymous]

У меня есть таймер, который я пытаюсь закрыть в методе удаления, но мне нужно быть на 100% уверенным, что он завершил работу и у нас больше нет случайных обратных вызовов к ElapsedEventHandler.
Я знаю, что вы не могу проверить, завершились ли обратные вызовы, поэтому я пытаюсь охватить все основы, чтобы гарантировать, что сбоев не произойдет и все сообщения будут удалены из моей очереди.
Я реализовал bool StopTimer, поэтому таймер не перезапустится, пока я утилизирую.
У меня есть метод SemaphoreSlim, блокирующий истекшие таймеры.
Я установил задержку, равную 2-кратному интервалу времени, истекшему таймерами, чтобы гарантировать таймер должен был завершить свой последний цикл.
Я также не уверен, правильный ли это подход, или мне следует просто остановить таймер и позволить GC позаботиться об очистке?< /p>
public class MessageWriter : IDisposable
{
public delegate void WriteMessageDelegate(OutputMessage messageQueue);
private ConcurrentQueue MessageQueue = new ConcurrentQueue();
public WriteMessageDelegate OutputToDevice;

private System.Timers.Timer WriteTimer { get; set; }
public int TimerInterval { get; set; }
private SemaphoreSlim WritingMessages;
private bool RunTimer { get; set; }

private bool _disposed = false;

public MessageWriter(double timerInterval)
{
TimerInterval = TimerInterval;

RunTimer = true;

WritingMessages = new SemaphoreSlim(1);

WriteTimer = new System.Timers.Timer();
WriteTimer.AutoReset = false;
WriteTimer.Interval = TimerInterval;
WriteTimer.Elapsed += WriteTimerElapsed;
}

private void WriteTimerElapsed(object sender, ElapsedEventArgs e)
{
try
{
WritingMessages.Wait();

EmptyQueue();

if (RunTimer)
WriteTimer.Start();
}
catch (Exception)
{
//Nothing we can do here, this is the logger
Console.WriteLine("Exception with Log timer - : " + ex.Message);
}
finally
{
WritingMessages.Release();
}
}

private void EmptyQueue()
{
while (MessageQueue.TryDequeue(out var message))
{
OutputToDevice?.Invoke(message);
}
}

protected virtual void Dispose(bool disposing)
{
if (_disposed)
return;

if (disposing)
{
}

//Prevent timer running again
RunTimer = false;

//Disable timer if its running
if (WriteTimer != null)
{
WriteTimer.Enabled = false;
WriteTimer.Stop();
WriteTimer.Dispose();
}

//Wait for double the timer interval
System.Threading.Thread.Sleep(TimerInterval + TimerInterval);

//Wait until this message writer has finished
WritingMessages.Wait();

//Release the semaphore so the timer can run again if it needs to
WritingMessages.Release();

//Get rid of any messages left in the queue
EmptyQueue();

//Dispose of the delegate
OutputToDevice = null;

// Free any unmanaged objects here.
_disposed = true;
}

public void Dispose()
{
Dispose(true);
GC.SuppressFinalize(this);
}

~MessageWriter()
{
Dispose(false);
}
}


Подробнее здесь: https://stackoverflow.com/questions/788 ... s-finished