C# 中的可调服务定时器

Question

我正在尝试编写一个无限期运行的 Windows 服务。 Linux 的 Windows 窗体和后台程序看起来还不错，但也许我只是在 Windows 服务方面非常无能。与我在这里挖掘的其他一些与睡眠或计时器相关的问题不同，醒来或睡觉的时间可以是有规律的间隔，但并不总是这样。该程序从一些数据文件中读取这些数据文件，这些数据文件可能指示它更改自己的计划，并且这必须在下次唤醒时间生效。作为一个控制台程序，它看起来很简单，并且在那里表现得很完美：

while (true)
{
  // Calculate next time to run.
  DateTime nextRun = NextWakeup();
  TimeSpan nextTime = nextRun - DateTime.Now;
  int sleepMs = (int)nextTime.TotalMilliseconds;
  // Sleep until scheduled time
  System.Threading.Thread.Sleep(sleepMs);
  // Do a code cycle of more stuff here...
}

但是，当我尝试将它作为服务的一部分运行以便它在用户注销时继续处于活动状态时，服务管理器顽固地拒绝启动它。我收到可爱的 1053 错误，“服务没有及时响应启动或控制请求。”

这里相关问题的很多答案似乎都建议不惜一切代价使用计时器而不是线程休眠。如果我做了这样的事情而不是 while/sleep 组合，我将如何在每次运行时更改计时器间隔？或者这一切都很好，但我要错误地设置我的服务？

非常感谢！

Answer 1

Windows 服务通常必须在 30 秒内响应控制请求（通常是启动/停止，但也包括暂停/恢复）。这意味着如果您在 OnStart 中休眠主线程，您的服务将返回您引用的错误。

解决问题的方法是在单独的线程上完成工作，您可以按照您描述的方式自由地休眠线程。只需在服务的 OnStart 中启动此线程，您应该能够在 30 秒的限制内轻松返回。

顺便说一句，您应该考虑被停止的服务也必须在 30 秒限制内返回，而不是 while(true)。如果您有一个线程处于睡眠状态，那么如果不中止线程（不好）或提供某种正确退出线程的机制，服务将无法正确关闭。这正是大多数人采用投票方式的原因；该服务既可以确定是否到了运行时间，也可以确定是否发生了停止请求。只要轮询频率小于 30 秒，服务就会始终正常关闭。

Answer 2

如果你想使用计时器，这很容易做到。我会使用 System.Timers.Timer 并更改它的间隔就像 mytimer.Inverval = nextTime.Seconds 或类似的一样简单。

我个人会在没有 AutoReset = false 的情况下运行计时器（因此它不会自动重新启动计时器），然后每次它醒来时都会运行您的“dowork”，然后在 dowork 结束时您计算出下次运行的时间，设置适当的时间间隔，然后再次调用计时器上的“开始”。

当然，在您的服务中，您的启动方法只是设置第一个计时器运行然后返回，以便启动又好又快。关闭时，您只需清理计时器（停止并处理等），然后返回即可。漂亮又干净。

Answer 3

我想你可能正在寻找这样的东西：

static class ConsoleProgram
{
    static void Main()
    {
        ServiceBase[] servicesToRun = new ServiceBase[] { new MyService(config, Logger) };
        ServiceBase.Run(servicesToRun);
    }
}



public partial class MyService : ServiceBase
{
    private bool _stopped = true;

    protected override void OnStart(string[] args)
    {
        StartTimer();
    }

    protected override void OnStop()
    {
        StopTimer();
    }

    public void StartTimer()
    {
        _stopped = false;
        Timer t = new Timer(TimerProc);
        // Calculate your desired interval here.
        t.Change(_config.Interval, new TimeSpan(0, 0, 0, 0, -1));
    }

    public void StopTimer()
    {
        _stopped = true;
    }

    private void TimerProc(object state)
    {
        // The state object is the Timer object.
        Timer t = (Timer) state;
        t.Dispose();

        ThreadPool.QueueUserWorkItem(DoWork);

        if (!_stopped) {
            StartTimer();
        }
    }

}