कार्य। प्रतीक्षा करें बच्चे के काम की प्रतीक्षा नहीं करता है?

Question

हैलो मेरे पास _noOfThreads एक समय में चलाने के लिए निर्धारित कार्यों के रूप में है। इसलिए मैं % ऑपरेटर का उपयोग करके कार्य जारी रखता हूं और लूप के अंत में मेरे पास Tasks.WaitAll है। यह कोड स्निपेट है।

for (int index = 0; index < count; index++) 
{ 

       if (index < _noOfThreads) 
        tasks[index] = Task.Factory.StartNew(somedelegate); 
       else 
        tasks[index % _noOfThreads].ContinueWith(task => { foo.bar(); }, 
          TaskContinuationOptions.AttachedToParent); 
} 
    Task.WaitAll(tasks); 

हालांकि, मुझे लगता है कि यह बाल कार्यों को पूरा करने की प्रतीक्षा नहीं करता है। जैसे ही मूल कार्य पूर्ण हो जाते हैं, Task.WaitAll के बाद अगली पंक्ति निष्पादित हो जाती है। बाल कार्यों के इंतजार के लिए मैं इस कोड को कैसे बदलूं?

Answer 1

मुझे लगता है कि आप के रूप में अपने कार्य का आवंटन किया गया है:

Tasks[] tasks = new Task[ _noOfThreads]; 

होने के लिए अपने कोड में परिवर्तित करें:

Tasks[] tasks = new Task[count]; 

for (int index = 0; index < count; index++) 
{ 

    if (index < _noOfThreads) 
     tasks[index] = Task.Factory.StartNew(somedelegate); 
    else 
     tasks[index] = tasks[index % _noOfThreads].ContinueWith(task => { foo.bar(); }, 
          TaskContinuationOptions.AttachedToParent); 
} 
Task.WaitAll(tasks); 

एक बार इसे आज़माएं! शुभकामनाएँ :)

Answer 2

आप केवल मूल कार्य के लिए प्रतीक्षा कर रहे हैं। सभी निरंतरताओं को पूरा करने के लिए प्रतीक्षा करने के लिए, आपको निरंतर कार्यों पर WaitAll पर कॉल करने की आवश्यकता है। सरल तरीका यह है, ताकि आप केवल अंतिम निरंतरता पर इंतजार कर रहे हैं मूल चर करने के लिए वापस प्रत्येक निरंतरता कार्य पुन: असाइन करने होगा:

else 
    tasks[index % _noOfThreads] = 
     tasks[index % _noOfThreads].ContinueWith(task => { foo.bar(); }, 
         TaskContinuationOptions.AttachedToParent); 

भी देखें this related question।