Таймер для опроса службы Windows

Прежде всего, вы можете использовать System.Threading.Timer вместо этого таймера, так как, согласно моему опыту, это более эффективный таймер (просто совет по личному опыту).

Во-вторых, в таких случаях вы должны указать флаг, который устанавливается после завершения задачи более ранним таймером (этот флаг - статическое поле, к которому обращаются все потоки).

В этом случае убедитесь, что в случае какой-либо ошибки флаг также сбрасывается вами, чтобы другой таймер не ждал бесконечно, если задача таймера не может установить флаг для других таймеров из-за ошибки, возникшей внутри задача (следует добавить своего рода последний блок, чтобы гарантировать, что ошибка обрабатывается, а флаг всегда сбрасывается).

Как только этот флаг сброшен, следующий поток работает с ним, поэтому эта проверка гарантирует, что все потоки запускают задачу на одном и том же один за другим.

Пример кода, который я написал для такой ситуации (код методов был удален, это даст вам детали дизайна).

namespace SMSPicker
{
 public partial class SMSPicker : ServiceBase{
    SendSMS smsClass;
    AutoResetEvent autoEvent;
    TimerCallback timerCallBack;
    Timer timerThread;
    public SMSPicker()
    {
        InitializeComponent();
    }

    protected override void OnStart(string[] args)
    {
        // TODO: Add code here to start your service.
        smsClass = new SendSMS();
        autoEvent = new AutoResetEvent(false);
        long timePeriod = string.IsNullOrEmpty(ConfigurationSettings.AppSettings["timerDuration"]) ? 10000 : Convert.ToInt64(ConfigurationSettings.AppSettings["timerDuration"]);
        timerCallBack = new TimerCallback(sendSMS);
        timerThread = new Timer(timerCallBack, autoEvent, 0, timePeriod);
    }


    private void sendSMS(object stateInfo)
    {
        AutoResetEvent autoResetEvent = (AutoResetEvent)stateInfo;
        smsClass.startSendingMessage();
        autoResetEvent.Set();
     }

    protected override void OnStop()
    {
        // TODO: Add code here to perform any tear-down necessary to stop your service.
        smsClass.stopSendingMessage();
        timerThread.Dispose();            

    }
}
}







namespace SMSPicker
{
class SendSMS
{
    //This variable has been done in order to ensure that other thread does not work till this thread ends
    bool taskDone = true;
    public SendSMS()
    {

    }

    //this method will start sending the messages by hitting the database
    public void startSendingMessage()
    {

        if (!taskDone)
        {
            writeToLog("A Thread was already working on the same Priority.");
            return;
        }

        try
        {
        }
        catch (Exception ex)
        {
            writeToLog(ex.Message);
        }
        finally
        {
            taskDone = stopSendingMessage();

            //this will ensure that till the database update is not fine till then, it will not leave trying to update the DB
            while (!taskDone)//infinite looop will fire to ensure that the database is updated in every case
            {
                taskDone = stopSendingMessage();
            }
        }

    }


public bool stopSendingMessage()
    {
        bool smsFlagUpdated = true;
        try
        {

        }
        catch (Exception ex)
        {
            writeToLog(ex.Message);
        }
        return smsFlagUpdated;
    }

}
}

Другим способом сделать это было бы ожидание события, а не использование таймера.

открытый класс PollingService { частный поток _workerThread; частный AutoResetEvent _finished; частная константа int _timeout = 60*1000;

public void StartPolling()
{
    _workerThread = new Thread(Poll);
    _finished = new AutoResetEvent(false);
    _workerThread.Start();
}

private void Poll()
{
    while (!_finished.WaitOne(_timeout))
    {
        //do the task
    }
}

public void StopPolling()
{
    _finished.Set();
    _workerThread.Join();
}

}

В вашей службе

public partial class Service1 : ServiceBase
{
    private readonly PollingService _pollingService = new PollingService();
    public Service1()
    {
        InitializeComponent();
    }

    protected override void OnStart(string[] args)
    {
        _pollingService.StartPolling();
    }

    protected override void OnStop()
    {
        _pollingService.StopPolling();
    }

}

У меня была похожая проблема: проще было бы использовать System.Threading.Timer с периодом = 0;

В этом сценарии метод обратного вызова вызывается один раз. Затем сброс таймера (вызов его метода Change()) снова включает его; в конце вашего повторяющегося метода.

Этот сценарий объясняется здесь: http://kristofverbiest.blogspot.com/2008/08/timers-executing-task-at-regular.html

Вы можете использовать таймер или выделенный поток/задачу, которая спит или что-то еще. Лично мне проще работать с выделенным потоком/задачей, чем с таймером для таких вещей, потому что легче контролировать интервал опроса. Кроме того, вам обязательно следует использовать механизм совместной отмены, предоставляемый пакетом TPL. Не обязательно генерировать исключения. Это происходит только в том случае, если вы вызываете ThrowIfCancellationRequested. Вместо этого вы можете использовать IsCancellationRequested, чтобы просто проверить состояние токена отмены.

Вот очень общий шаблон, который вы можете использовать для начала.

public class YourService : ServiceBase
{
  private CancellationTokenSource cts = new CancellationTokenSource();
  private Task mainTask = null;

  protected override void OnStart(string[] args)
  {
    mainTask = new Task(Poll, cts.Token, TaskCreationOptions.LongRunning);
    mainTask.Start();
  }

  protected override void OnStop()
  {
    cts.Cancel();
    mainTask.Wait();
  }

  private void Poll()
  {
    CancellationToken cancellation = cts.Token;
    TimeSpan interval = TimeSpan.Zero;
    while (!cancellation.WaitHandle.WaitOne(interval))
    {
      try 
      {
        // Put your code to poll here.
        // Occasionally check the cancellation state.
        if (cancellation.IsCancellationRequested)
        {
          break;
        }
        interval = WaitAfterSuccessInterval;
      }
      catch (Exception caught)
      {
        // Log the exception.
        interval = WaitAfterErrorInterval;
      }
    }
  }
}