मल्टीथ्रेडेड/एसिंक अनुरोध और प्रतीक्षा करें जब तक कि वे सभी नहीं किए जाते हैं और फिर

Question

परिणामों को संसाधित करते हैं, मेरे पास एकाधिक स्रोतों के लिए एक खोज अनुरोध निष्पादित करने के लिए (चाहते हैं) है। अब मैंने अतीत में कुछ मल्टीथ्रेडिंग की है, लेकिन यह सब आग और भूल गई थी।

अब मैं क्या करना चाहता हूं, 3 अलग-अलग ऑब्जेक्ट्स पर 3 समान अनुरोधों को स्पिन करना है, जब तक कि वे सभी 'किए गए' तक प्रतीक्षा न करें (और यह मुझे पहला प्रश्न देता है: वे कैसे कहते हैं 'मैं कर रहा हूं' , और उसके बाद सभी डेटा thet've मुझे भेजा इकट्ठा

छद्म कोड में

तो मैं इस इंटरफेस है:।

ISearch s1 = new SearchLocal(); 
ISearch s2 = new SearchThere(); 
ISearch s3 = new SearchHere(); 

:

interface ISearch 
    SearchResult SearchForContent(SearchCriteria criteria) 

तो कोड में मैं तीन खोज सेवाओं को बनाने के और यह n उन सभी को तीन पर SearchForContent(SearchCriteria criteria) फोन, एक multihreaded/async रास्ता

में और वे सब उनके SearchResult साथ मेरे पास वापस आने के लिए और उसके बाद वे सभी से किया जाता है, मैं उनके SearchResult वस्तुओं की प्रक्रिया।

मुझे आशा है कि पाठ की इन पंक्तियों kindof तुम क्या मेरे सिर :)

मैं एक ASP.Net 3.5 सी # परियोजना पर काम कर रहा हूँ में है प्राप्त करता है।

Answer 1

AutoResetEvent बनाएँ और उन्हें WaitHandle.WaitAll()

के पास एक उदाहरण here नहीं है।

असल:

1) आप प्रत्येक खोज के लिए एक AutoResetEvent बना सकते हैं और इसके निर्माता को false गुजरती हैं।

2) धागे बनाएं और प्रत्येक के लिए और अंत में खोज चलाने, अंत में ब्लॉक में AutoResetEvent पर Set कहते हैं। यह बहुत महत्वपूर्ण है कि Set को कॉल करना आखिरकार ब्लॉक के अंदर किया जाता है अन्यथा WaitAll() अनिश्चित काल तक प्रतीक्षा करेगा।

3) कोड में थ्रेड बनाने के ठीक बाद कोड में, आप WaitHandle.WaitAll() पर कॉल करें और उन सभी AutoResetEvent को पास करें। यह कोड तक पूरा होने तक प्रतीक्षा करेगा।

Answer 2

IEnumerable<ISearch> बनाएं, और उन वस्तुओं को, और .AsParallel().ForAll(...) पर करें।

संपादित

forall परिणाम नहीं देंगे, तो आप iSearch बदल सकते हैं, यह परिणामों के लिए एक संपत्ति है, तो दे एक बार forall किया जाता है आप IEnumerable के माध्यम से परिणाम देख सकते हैं।

और हाँ, क्षमा करें, यह 4.0 है।

Answer 3

कार्यों का उपयोग करके आप इस तरह एक निरंतरता कर सकता है:

 Task[] t = new Task[2]; 
     t[0] = Task.Factory.StartNew(() => { Thread.Sleep(1000); }); 
     t[1] = Task.Factory.StartNew(() => { Thread.Sleep(2000); }); 

     Task.Factory.ContinueWhenAll(t, myTasks => { Console.WriteLine("All done!"); });