Wie führen Sie mehrere Aufgaben in C# aus und erhalten ein Ereignis nach Abschluss dieser Aufgaben?

Question

Ich führe eine Task erneut, wenn es abgeschlossen ist. Unten ist die Funktion, die ich in der Application_Start meiner Anwendung aufrufen.

private void Run() 
{ 
    Task t = new Task(() => new XyzServices().ProcessXyz()); 
    t.Start(); 
    t.ContinueWith((x) => 
    { 
     Thread.Sleep(ConfigReader.CronReRunTimeInSeconds); 
     Run(); 
    }); 
} 

Ich möchte mehrere Aufgaben ausführen, Nummer, die von web.config App Settings gelesen werden.

ich so etwas wie dies versuchen,

private void Run() 
{ 
    List<Task> tasks = new List<Task>(); 
    for (int i = 0; i < ConfigReader.ThreadCount - 1; i++) 
    { 
     tasks.Add(Task.Run(() => new XyzServices().ProcessXyz())); 
    } 

    Task.WhenAll(tasks); 

    Run(); 
} 

Was ist der richtige Weg, dies zu tun?

Answer 1

Ich glaube, Sie suchen:

Task.WaitAll(tasks.ToArray()); 

https://msdn.microsoft.com/en-us/library/dd270695(v=vs.110).aspx

Answer 2

Wenn Sie alle Aufgaben warten möchten zu beenden und starten Sie sie, Marks Antwort richtig ist.

Aber wenn Sie wollen Thread Aufgaben jederzeit ausgeführt werden (sobald eine neue Aufgabe beginnen, wie jeder von ihnen endet), dann

void Run() 
{ 
    SemaphoreSlim sem = new SemaphoreSlim(ConfigReader.ThreadCount); 

    Task.Run(() => 
    { 
     while (true) 
     { 
      sem.Wait(); 
      Task.Run(() => { /*Your work*/ }) 
       .ContinueWith((t) => { sem.Release(); }); 
     } 
    }); 
} 

Answer 3

, wenn Sie die Aufgaben, die man ausführen möchten nach die andere,

await Task.Run(() => new XyzServices().ProcessXyz()); 
await Task.Delay(ConfigReader.CronReRunTimeInSeconds * 1000); 

wenn Sie wollen, gleichzeitig ausgeführt werden, wie die Task-Scheduler erlaubt,

await Task.WhenAll(new[] 
    { 
     Task.Run(() => new XyzServices().ProcessXyz()), 
     Task.Run(() => new XyzServices().ProcessXyz()) 
    }); 

---

So sollte Ihre Methode so etwas wie,

private async Task Run() 
{ 
    var tasks = 
     Enumerable.Range(0, ConfigReader.ThreadCount) 
     .Select(i => Task.Run(() => new XyzServices().ProcessXyz())); 

    await Task.WhenAll(tasks); 
}