सी # में एकाधिक कार्यों को कैसे चलाएं और इन कार्यों को पूरा करने पर कोई ईवेंट प्राप्त करें?

Question

मैं इसे पूरा होने पर Task फिर से चला रहा हूं। नीचे वह कार्य है जिसे मैं अपने आवेदन के Application_Start में कॉल करता हूं।

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

मैं कई कार्यों को चलाने के लिए चाहता हूं, संख्या जो web.config ऐप सेटेटिंग से पढ़ी जाएगी।

मैं कुछ इस तरह कोशिश कर रहा हूँ,

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

क्या सही तरीका यह करने के लिए?

Answer 1

मेरा मानना ​​है कि आप देख रहे हैं:

Task.WaitAll(tasks.ToArray()); 

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

Answer 2

आप समाप्त करने के लिए सभी कार्य प्रतीक्षा करें और उन्हें फिर पुन: प्रारंभ करना चाहते हैं, मार्क्स का जवाब सही है।

लेकिन अगर आप चाहते हैं THREADCOUNT कार्य,

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

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

Answer 3

किसी भी समय चल रहा हो (जैसे ही कोई नया कार्य शुरू के रूप में उनमें से किसी एक समाप्त होता है) तो अगर आप के बाद कार्य एक चलाना चाहते हैं अन्य,

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

अगर तुम उन्हें समवर्ती चलाने के लिए, कार्य अनुसूचक परमिट के रूप में चाहते हैं,

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

---

तो, अपने विधि, की तरह कुछ होना चाहिए

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

    await Task.WhenAll(tasks); 
}