我可以使用 Task.Delay 作为计时器吗？

Question

我想每秒执行一些代码。我现在使用的代码是：

Task.Run((Action)ExecuteSomething);

而ExecuteSomething()定义如下：

 private void ExecuteSomething()
        {
            Task.Delay(1000).ContinueWith(
               t =>
               {
                   //Do something.

                   ExecuteSomething();
               });
        }

这个方法会阻塞线程吗？还是应该在 C# 中使用 Timer 类？而且好像Timer also dedicates a separate thread for execution (?)

Answer 1

Task.Delay 内部使用Timer

使用Task.Delay，您可以使您的代码比使用Timer 更清晰。并且使用async-await不会阻塞当前线程（通常是UI）。

public async Task ExecuteEverySecond(Action execute)
{
    while(true)
    {
        execute();
        await Task.Delay(1000);
    }
}

来自源代码：Task.Delay

// on line 5893
// ... and create our timer and make sure that it stays rooted.
if (millisecondsDelay != Timeout.Infinite) // no need to create the timer if it's an infinite timeout
{
    promise.Timer = new Timer(state => ((DelayPromise)state).Complete(), promise, millisecondsDelay, Timeout.Infinite);
    promise.Timer.KeepRootedWhileScheduled();
}

// ...

Answer 2

Microsoft 的响应式框架非常适合这一点。只需 NuGet “System.Reactive” 即可获取这些信息。然后你可以这样做：

IDisposable subscription =
    Observable
        .Interval(TimeSpan.FromSeconds(1.0))
        .Subscribe(x => execute());

如果您想停止订阅，只需致电subscription.Dispose()。除此之外，响应式框架可以提供比任务或基本计时器更多的功能。

Answer 3

你可以使用 Task.Delay 作为计时器吗？这取决于您是需要等待一个确切的时间间隔，还是只需要在其他工作完成后等待指定的时间间隔。

换句话说，我过去曾多次使用 Timer 作为服务的一部分，该服务为同步目的而获取或推送数据。问题是，如果您每 60 秒获取一次数据，但数据库速度很慢，并且您的检索需要超过 60 秒。现在您遇到了一个问题，因为您将要获取相同的数据两次。因此，您更新该过程，以便停止计时器直到它完成，然后再次启动计时器。这工作正常，但使用 Task.Delay 可以为您工作。

因此，如果您只需要在两次执行之间延迟一点时间，那么 Task.Delay 就可以完美运行。

Answer 4

static class Helper
{
    public async static Task ExecuteInterval(Action execute, int millisecond, IWorker worker)
    {
        while (worker.Worked)
        {
            execute();

            await Task.Delay(millisecond);
        }
    }
}


interface IWorker
{
    bool Worked { get; }
}