टीपीएल डेटाफ्लो, कई लिंक किए गए लक्ष्य ब्लॉक के बीच आइटम को केवल एक विशिष्ट लक्ष्य ब्लॉक में कैसे अग्रेषित करें?

Question

मैं एक टीपीएल डेटा फ्लो ब्लॉक समाधान की तलाश में हूं जो एक से अधिक आइटम धारण कर सकता है, जो एकाधिक लक्ष्य ब्लॉक से लिंक कर सकता है, लेकिन जिसमें किसी आइटम को केवल एक विशिष्ट लक्ष्य ब्लॉक में भेजने की क्षमता है जो फ़िल्टर/भविष्यवाणी करता है । किसी भी समय एक आइटम को एक ही समय में एकाधिक लक्ष्य ब्लॉक पर वितरित नहीं किया जाना चाहिए, हमेशा फ़िल्टर या आइटम से मेल खाने वाले व्यक्ति को ही त्याग दिया जा सकता है। मुझे ब्रॉडकास्टब्लॉक का शौक नहीं है क्योंकि, अगर मैं सही ढंग से समझता हूं, तो यह डिलीवरी की गारंटी नहीं देता है (या यह करता है?) और फ़िल्टरिंग ब्लॉक ब्लॉक पर फ़िल्टरिंग किया जाता है, जिसका अर्थ है ब्रॉडकास्टब्लॉक अनिवार्य रूप से प्रत्येक आइटम की प्रतियों को सभी लिंक से लक्षित ब्लॉक पर भेजता है। यदि मैं सही ढंग से समझता हूं तो यह किसी भी समय एक से अधिक आइटम नहीं रखता है। मैं पोस्ट/असिंक का उपयोग नहीं करना चाहता हूं लेकिन लिंकटो चेन बनाए रखता हूं।

क्या कोई कस्टम कस्टम डेटा प्रवाह ब्लॉक के आसपास कोई तरीका है? या क्या मैं गलत समझ रहा हूं कि ब्रॉडकास्टब्लॉक कैसे काम करता है? दुर्भाग्यवश वहां वास्तव में बहुत अधिक दस्तावेज नहीं हैं जो विस्तार से आगे बढ़ते हैं और मामलों का उपयोग करते हैं। किसी भी विचार की अत्यधिक सराहना की जाती है।

Answer 1

यदि मैं आपको सही ढंग से समझता हूं, तो आप जो चाहते हैं उसे सरल BufferBlock द्वारा पूरा किया जा सकता है, जो भविष्य के साथ आपके सभी लक्षित ब्लॉक से जुड़ा होगा। मिलान करने वाली वस्तुओं को त्यागने के लिए आप इसे बिना किसी शर्त के NullTarget block पर लिंक भी करेंगे।

कुछ की तरह:

var forwarder = new BufferBlock<SomeType>(); 
forwarder.LinkTo(target1, item => matchesTarget1(item)); 
forwarder.LinkTo(target2, item => matchesTarget2(item)); 
forwarder.LinkTo(DataflowBlock.NullTarget<SomeType>()); 

इस तरह, प्रत्येक आइटम पहले लक्ष्य है कि, से मेल खाता है, अगर वहाँ किसी भी करने के लिए भेजा जाएगा।

BroadcastBlock उपयोगी हो सकता है यदि आप प्रत्येक आइटम को एकाधिक लक्ष्यों पर भेजना चाहते हैं, या यदि आप लक्ष्य ब्लॉक पर्याप्त तेज़ नहीं हैं तो आइटम को त्यागना चाहते हैं।

BroadcastBlock के साथ, यदि कोई ब्लॉक उन्हें स्वीकार नहीं करता है तो आइटम गिराए जा सकते हैं (भले ही वे इसे बाद में स्वीकार कर सकें)। लेकिन यह आइटम को यादृच्छिक रूप से नहीं छोड़ता है, इसलिए यदि आपके लक्षित ब्लॉक में BoundedCapacity सेट नहीं है, तो मुझे लगता है कि आप यह सुनिश्चित कर सकते हैं कि वे उन सभी आइटमों को प्राप्त करेंगे जिन्हें वे अस्वीकार नहीं करते हैं (उदाहरण के लिए LinkTo() में भविष्यवाणी का उपयोग करके)।

Answer 2

मुझे स्वीकार्य उत्तर गलत होने का पता चला है। NullTarget को अपने भविष्य के साथ अपने उपभोक्ताओं की अस्वीकृति के साथ जोड़ा जाना चाहिए। अन्यथा आप उन संदेशों को छोड़ सकते हैं जिन्हें आप उपभोग करना चाहते थे।

var forwarder = new BufferBlock<SomeType>(); 
forwarder.LinkTo(target1, item => matchesTarget1(item)); 
forwarder.LinkTo(target2, item => matchesTarget2(item)); 
forwarder.LinkTo(DataflowBlock.NullTarget<SomeType>(), item => !matchesTarget1(item) && !matchesTarget2(item));