Как запустить задачу при запуске службы Windows?

Question

У меня есть служба Windows, и я написал код для выполнения задачи в случае OnStart():

protected override void OnStart(string[] args) 
     { 
      this.DoTask(); 
     } 

private void DoTask() 
     { 
      Task task1 = Task.Factory.StartNew(() => this.OriginalFileProcessor.StartPolling()); 

      try 
      { 
       Task.Wait(task1); 
      } 
      catch (Exception ex) 
      { 
       this.Log.Error("Failed running the task", ex); 
      }   
     } 

Выполнитезадачи это нескончаемый цикл. Он останавливается только тогда, когда служба остановлена.

Но когда я пытаюсь запустить службу, он ждет много времени, а затем дает мне ошибку ниже:

Windows could not start the ... service on Local Computer. 
Error 1053: The service did not respond to the start or control request in a timely fashion. 

Как решить это?

Answer 1

Почему вы ожидали, что ваша задача будет завершена?

Я думаю, что Task.Wait блокирует ваш текущий поток, тогда вы получаете таймаут при запуске службы.

EDIT: Вы должны удалить этот блок:

try 
{ 
    Task.Wait(task1); 
} 
catch (Exception ex) 
{ 
    this.Log.Error("Failed running the task", ex); 
} 

Task.Wait действительно блокирует текущий поток. По MSDN:

Task.Wait Method

Waits for the Task to complete execution.

EDIT 2 ли это вместо

Task task1 = Task.Factory.StartNew(() => this.OriginalFileProcessor.StartPolling()).ContinueWith(t => 
{ 
    var aggException = t.Exception.Flatten(); 
    foreach(var ex in aggException.InnerExceptions) 
     this.Log.Error("Failed running the task", ex); 
}, 
TaskContinuationOptions.OnlyOnFaulted); 

Answer 2

В цикле вы должны проверить, «статус остановки» остановлен и выйти из цикла. У вас есть 5 секунд, чтобы сделать это до того, как ОС решит вас убить.

Answer 3

Я предполагаю, что это, потому что вы ждете OriginalFileProcessor.StartPolling() до конца, но это никогда не случится. Вы должны перенести свой экземпляр задачи в отдельного члена и не дожидаться его завершения:

private Task m_task = null; 

private void DoTask() 
{ 
    try 
    { 
     m_task = Task.Factory.StartNew(() => this.StartPolling()); 
    } 
    catch 
    { 
     this.Log.Error("Unable to start task", ex); 
     throw; // Rethrow, so that the OS knows, there was something wrong. 
    }   
} 

private void StartPolling() 
{ 
    try 
    { 
     this.OriginalFileProcessor.StartPolling(); 
    } 
    catch (Exception ex) 
    { 
     this.Log.Error("Failed running the task", ex); 
    } 
}