Сообщите, продолжается ли поток «прошедших» событий?
Учитывая System.Timers.Timer, есть ли способ из основного потока узнать, работает ли рабочий поток, выполняющий прошедший код события?
Другими словами, как можно убедиться, что код, работающий в рабочем потоке, в настоящее время не выполняется, прежде чем останавливать таймер или основной поток приложения / службы, в котором работает таймер?
Это вопрос отказа от таймера для потокового таймера, использующего состояние, или просто пора использовать потоки напрямую?
Ответы 2
Для нестандартного решения нет выхода. Основная причина заключается в том, что поток, выполняющий функцию TimerCallback, по всей вероятности, все еще жив, даже если код, выполняющий обратный вызов, завершился. TimerCallback выполняется потоком из пула потоков. Когда задача завершена, поток не умирает, а вместо этого возвращается в очередь для следующей задачи пула потоков.
Для того, чтобы заставить это работать, вам придется использовать потокобезопасную сигнализацию, чтобы обнаружить, что операция завершена.
Найдите ManualResetEvent, поскольку он создан специально для того, что вы просите.
Ваши потоки создают новое событие сброса и добавляют его в доступную очередь, которую ваш основной поток может использовать, чтобы увидеть, работают ли еще какие-либо потоки.
// main thread owns this
private List<ManualResetEvent> _resetEvents;
...
// main thread does this to wait for executing threads to finish
WaitHandle.WaitAll(_resetEvents.ToArray(), 2000, false)
...
// worker threads do this to signal the thread is done
myResetEvent.Set();
Я могу дать вам больше примеров кода, если хотите, но я просто скопировал его из пары статей, которые читал, когда мне приходилось делать это год назад или около того.
Забыл упомянуть, что вы не можете добавить эту функцию к потокам по умолчанию, которые вы получите, когда сработает ваш таймер. Таким образом, вы должны сделать свой обработчик таймера очень компактным и ничего не делать, кроме подготовки и запуска нового рабочего потока.
...
ThreadPool.QueueUserWorkItem(new WaitCallback(MyWorkerDelegate),
myCustomObjectThatContainsAResetEvent);