从 Threading.Timer 只调用一次方法

Question

我有一个 System.Threading.Timer 频繁触发（为了简单起见，我们说每秒一次），在 CallBack 中我需要调用一个 Action（通过构造函数传入，因此位于另一个类中），我在其中做一些处理（假设需要 2 秒以上），我将如何防止我的处理逻辑被多次调用？似乎 lock() 在 Action 调用中不起作用？ 我使用的是 .net 3.5。

public TestOperation(Action callBackMethod)
{
    this.timer = new System.Threading.Timer(timer_Elapsed, callbackMethod, timerInterval, Timeout.Infinite);
}

private void timer_Elapsed(object state)
{
    Action callback = (Action) state;
    if (callback != null)
    {
        callback();
    }
}

// example of the callback, in another class. 
private void callBackMethod()
{
    // How can I stop this from running every 1 second? Lock() doesn't seem to work here
    Thread.Sleep(2000);
}

谢谢！

Answer 1

您可以使用布尔标志来防止重入：

    bool executing;

    public TestOperation(Action callBackMethod)
    {
        this.timer = new System.Threading.Timer(timer_Elapsed, callbackMethod, timerInterval, Timeout.Infinite);
    }

    private void timer_Elapsed(object state)
    {
        if(executing)
             return;


        Action callback = (Action) state;
        if (callback != null)
        {
            executing = true;
            callback();
        }

    }

    // example of the callback, in another class. 
    private void callBackMethod()
    {
        // How can I stop this from running every 1 second? Lock() doesn't seem to work here

        Thread.Sleep(2000);
        executing = false;

    }

Answer 2

你可以这样做并完全避免使用计时器。

void Main()
{
    RunPeriodicAsync();
}
async Task RunPeriodicAsync()
{
    while(true)
    {
        await Task.Delay(someTimeSpan);
        DoTheThing();
        if(!goAgain)break;
    }

}

或者如果您需要支持取消：

void Main()
{
    var cts=new CancellationTokenSource();
    RunPeriodicAsync(cts.Token);
    //sometime later
    cts.Cancel();
}
async Task RunPeriodicAsync(CancellationToken ct)
{
    while(!ct.IsCancellationRequested)
    {
        await Task.Delay(1000);
        DoTheWork();
    }
}

没有 async/await 你可以：

System.Threading.Timer timer;
void Main()
{
    RunActionAfter(() => DoTheWork(), 2000);
}
void RunActionAfter(Action action, int period)
{
    //Timeout.Infinite means the timer runs only once.
    timer = new Timer(_ => action(), null, 2000, Timeout.Infinite); 
}
void DoTheWork()
{
    Console.WriteLine("!!!");

    //then maybe
    RunActionAfter(() => DoTheWork(),2000);
}

Answer 3

解决这个问题没什么好说的。请注意，使用 lock 是一个非常糟糕的主意，当回调持续​​花费太多时间时，它会使您的线程池爆炸。机器加载时很容易发生这种情况。使用 Monitor.TryEnter() 是安全的选择。肯定也不漂亮，你会随意丢失回调。

如果您简单地将 period 参数设置为 0，它会变得更容易。这样计时器只能滴答一次。现在，您自动获得了无法重新输入回调的硬性保证。您所要做的就是在方法结束时调用 Change() 来重新启动计时器。您可以选择使用固定值还是根据实际过期时间计算新的 dueTime 值，这都是合理的选择。