सी # में सही फ़ंक्शन पाइपलाइन को कैसे कार्यान्वित करें?

Question

सी # का उपयोग कर एक सच्ची फ़ंक्शन पाइपलाइन कैसे बनाएं? मैं इस प्रकार है जैसे कुछ विचार आया, लेकिन यह एक सच पाइपलाइन

public static IEnumerable<T> ForEachPipeline<T>(this IEnumerable<T> source, params Func<T, T>[] pipeline) 
{ 
foreach (var element in source) { 
    yield return ExecutePipeline(element, pipeline); 
} 
} 

private static T ExecutePipeline<T>(T element, IEnumerable<Func<T, T>> jobs) 
{ 
var arg = element; 
T result = default(T); 
foreach (var job in jobs) { 
    result = job.Invoke(arg); 
    arg = result; 
} 
return result; 
} 

ऊपर कोड IEnumerable<T> के प्रत्येक तत्व पाइपलाइन के बाद ही पिछले तत्व सभी कार्यों को क्रियान्वित खत्म में प्राप्त करने में सक्षम हैं में नहीं है (यानी बाहर निकलता है पाइपलाइन), लेकिन परिभाषा के अनुसार element1func1 निष्पादित करने को समाप्त करता है और func2 निष्पादित करना प्रारंभ करता है, उस समय तक element2 को func1 निष्पादित करना प्रारंभ करना चाहिए और इस प्रकार पाइपलाइन में डेटा का प्रवाह जारी रखना जारी रखना चाहिए।

क्या इस तरह का परिदृश्य सी # में लागू करना संभव है? यदि संभव हो तो कृपया मुझे कुछ उदाहरण कोड दें।

Answer 1

टिप्पणी से: धागे को पेश किए जाने तक केवल एक ही निष्पादन संदर्भ होता है (एकल-धागे के साथ वैकल्पिक दृष्टिकोण केवल प्रत्येक चरण में गैर आलसी परिणाम निर्माण होता है)। धागे के साथ, प्रत्येक चरण केवल एक "पंप" के आसपास संदेशों को पास करने वाली फीफो कतार है। धागे (वास्तव में, समरूपता) जटिलता में भी काफी वृद्धि करते हैं, शायद .NET4 "समांतर" विधियों को देखते हैं।

Parallel.ForEach का उपयोग करके एन "प्रारंभ" को कॉन्फ़िगर करने के लिए एक "आसान" विधि है - यदि केवल और यदि आप गारंटी दे सकते हैं कि गणनाएं दुष्प्रभाव मुक्त हैं।

संपादित करें: टिप्पणी देखें (ओं)।

Answer 2

यह व्यवहार एक वास्तविक पाइपलाइन से अधिक कुशल है। पाइपलाइनिंग केवल तभी समझ में आती है जब संचालन समानांतर में चलाया जा सके, लेकिन ये सभी नौकरियां एक एकल सीपीयू थ्रेड साझा कर रही हैं और इसलिए पाइपलाइन के बावजूद अनुक्रमिक रूप से निष्पादित करना आवश्यक है।

यदि आप समझते हैं कि कोई प्रदर्शन सुधार नहीं होगा और अभी भी पाइपलाइन करना चाहते हैं, तो एक टिप्पणी छोड़ दो और मैं दिखाऊंगा कि कैसे, लेकिन मैं पहले यह सुनिश्चित करना चाहता हूं कि आप जानते हैं कि आप क्या पूछ रहे हैं।

Answer 3

मेरा मानना ​​है कि एक मुख्य वास्तुकला तत्व गुम है, चाहे नौकरी संभाली गई हो या नहीं। पाइपलाइन बहुत जिम्मेदारी के पारंपरिक GOF श्रृंखला के लिए समान है, यदि आप चारों ओर GOF किताब नहीं है यहाँ एक बार देख ले:

http://www.dofactory.com/Patterns/PatternChain.aspx#_self1

मुझे लगता है कि आपको कुछ इंटरफ़ेस करने के लिए अपने "टी" प्रतिबंधित करने के लिए है कि अगर नौकरी संभाली गई थी तो पाइपलाइन बताती है ("कहां" कथन का उपयोग करें)।

इसके अलावा, PLINQ ढांचे में एक नज़र डालें। मुझे पता है कि यह वही नहीं है जो आप खोज रहे हैं (वहां, इरादा समानांतर में कई नौकरियों को निष्पादित करना है), लेकिन यह आपको कुछ अच्छे विचार दे सकता है।