TPL внутри службы Windows

Question

Мне нужно выполнить несколько задач внутри службы Windows, которую я пишу параллельно. Я использую VS2013, .NET 4.5, и этот поток Basic design pattern for using TPL inside windows service for C# показывает, что TPL - это путь.

Ниже приводится моя реализация. Мне было интересно, может ли кто-нибудь сказать мне, правильно ли я это сделал?

public partial class FtpLink : ServiceBase 
{ 
    private readonly CancellationTokenSource _cancellationTokenSource = new CancellationTokenSource(); 
    private readonly ManualResetEvent _runCompleteEvent = new ManualResetEvent(false); 

    public FtpLink() 
    { 
     InitializeComponent(); 

     // Load configuration 
     WebEnvironment.Instance.Initialise(); 
    } 

    protected override void OnStart(string[] args) 
    { 
     Trace.TraceInformation("DatabaseToFtp is running"); 

     try 
     { 
      RunAsync(_cancellationTokenSource.Token).Wait(); 
     } 
     finally 
     { 
      _runCompleteEvent.Set(); 
     } 
    } 

    protected override void OnStop() 
    { 
     Trace.TraceInformation("DatabaseToFtp is stopping"); 

     _cancellationTokenSource.Cancel(); 
     _runCompleteEvent.WaitOne(); 

     Trace.TraceInformation("DatabaseToFtp has stopped"); 
    } 

    private async Task RunAsync(CancellationToken cancellationToken) 
    { 
     while (!cancellationToken.IsCancellationRequested) 
     { 
      Trace.TraceInformation("Working"); 

      // Do the actual work 
      var tasks = new List<Task> 
      { 
       Task.Factory.StartNew(() => new Processor().ProcessMessageFiles(), cancellationToken), 
       Task.Factory.StartNew(() => new Processor().ProcessFirmware(), cancellationToken) 
      }; 

      Task.WaitAll(tasks.ToArray(), cancellationToken); 

      // Delay the loop for a certain time 
      await Task.Delay(WebEnvironment.Instance.DatabasePollInterval, cancellationToken); 
     } 
    } 
} 

Answer 1

Есть несколько вещей, которые я бы сделал по-другому:

1. OnStart должны выполняться своевременно. Обычная практика заключается в том, чтобы отложить работу до фонового потока, который отвечает за выполнение фактической работы. Вы на самом деле делаете это , но блокируете этот поток с вызовом Task.Wait, который делает разгрузку на фоновый поток бесполезным, потому что выполнение становится синхронным снова.
2. Вы используете sync over async anti-pattern, этого следует избегать. Пусть вызывающий метод вызывает работу параллельно.
3. Я думаю, вы можете использовать ManualResetEvent наоборот. Вы обматываете свой метод RunAsync в блоке try-finally, но вы вызываете только WaitOne от OnStop. Я не совсем уверен, что вам нужен замок здесь вообще, не кажется (из вашего текущего кода), что этот код вызывается параллельно. Вместо этого вы можете сохранить Task, возвращенный RunAsync, в поле и ждать его завершения.
4. Вы используете блокирующую версию, WaitAll. Вместо этого вы можете использовать асинхронную версию, Task.WhenAll, которую можно асинхронно ждать.