Jak uruchomić zadanie po uruchomieniu usługi systemu Windows?

Question

Mam usługa Windows i pisałem kod aby uruchomić zadanie w OnStart() imprezy:

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); 
      }   
     } 

DoTask to niekończąca się pętla. Zatrzyma się tylko wtedy, gdy usługa zostanie zatrzymana.

Ale gdy próbuję uruchomić usługę, to czeka długo potem daje mi poniższy błąd:

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. 

Jak go rozwiązać?

Answer 1

Dlaczego czekasz na zakończenie swojego zadania?

Myślę, że Task.Wait blokuje bieżący wątek, a następnie masz limit czasu podczas uruchamiania usługi.

EDIT: Trzeba usunąć ten blok:

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

Task.Wait rzeczywiście blokuje bieżącego wątku. Według MSDN:

Task.Wait Method

Waits for the Task to complete execution.

EDIT 2 Czy to zamiast

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

W pętli należy sprawdzić, czy stan usługi "zatrzymuje się" i wyjść z pętli. Masz 5 sekund na zrobienie tego, zanim OS zdecyduje cię zabić.

Answer 3

myślę, że to jest, bo czekają na OriginalFileProcessor.StartPolling() do końca, ale to nigdy nie zdarza. Powinieneś przenieść instancję zadania do osobnego członka i nie czekać na jego zakończenie:

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); 
    } 
}