如何确保计时器完全暂停?

How to ensure timer is fully paused?

假设我们将此事件附加到计时器事件处理程序。

private void TimerTick(object sender, ElapsedEventArgs e)
{
    if(_gaurd) return;
    lock (this) // lock per instance
    {
        _gaurd = true;
        if (!_timer.Enabled) return;

        OnTick(); // somewhere inside here timer may pause it self.

        _gaurd = false;
    }
}

现在有两件事可以暂停这个计时器。一是来自 UI 线程的用户请求,二是可能会自行暂停的计时器。

如果计时器自行暂停我们可以保证暂停会在我们继续之前完成。

timer.Stop();
OnPause(); // timer must be paused because OnPause() is not thread safe.

但是如果用户请求定时器暂停请求来自另一个线程并且我们不能保证定时器是否完全暂停。

timer.Stop();
OnPause(); // timer event may be still inside OnTick() and may conflict with OnPause()

-------------------------------------------- ---------------------------------------------- --------

所以我正在寻找一种方法使这个线程安全。到目前为止,这是我尝试过的方法,但我不确定这是否适用于所有情况。

它看起来不错,但我想确定是否有任何我不知道的地方。或者也许知道是否有更好的方法使这个进程线程安全。

我试图将用户请求与计时器的内部工作区分开来。因此我的计时器有两个暂停方法。

public class Timer
{
    internal void InternalStop() // must be called by timer itself.
    {
        timer.Pause(); // causes no problem
    }

    public void Stop() // user request must come here. (if timer call this deadlock happens)
    {
        InternalStop();
        lock (this) // reference of timer
        {
            // do nothing and wait for OnTick().
        }
    }
}

这不是实际代码,但行为相同。它应该说明这个 class 不是线程安全的。 :

public class WorkingArea
{
    private List<Worker> _workers;

    public void OnTick()
    {
        foreach(var worker in _workers)
        {
            worker.Start();
        }

        if(_workers.TrueForAll(w => w.Ends))
        {
            PauseTimer();
        }
    }

    public void OnPause() // after timer paused
    {
        foreach(var Worker in _workers)
        {
            worker.Stop();
        }
    }
}

我的定时器已经是线程安全的了。

都是因为我不知道 Re-entrant locks

因此,如果来自另一个线程的用户请求暂停计时器,lock 将正常工作并阻塞直到计时器完全暂停。

如果计时器在内部自行暂停,则不会处理锁。因为它在同一个线程中获得了锁。

public class Timer
{
    private timer = new System.Timers.Timer();

    private bool _guard = false;

    // stops the timer and waits until OnTick returns and lock releases.
    // timer can safely pause it self within OnTick.
    // if user request to pause from another thread, full pause is ensured
    public void Stop()       
    {
        timer.Pause();
        lock (this) // reference of timer. it wont dead lock
        {
            // do nothing and wait for OnTick().
        }
    }

    private void TimerTick(object sender, ElapsedEventArgs e)
    {
        if(_gaurd) return;
        lock (this) // lock per instance
        {
            _gaurd = true;
            if (!_timer.Enabled) return;

            OnTick(); // somewhere inside here timer may pause it self.

            _gaurd = false;
        }
    }
}