एक इनपुट स्ट्रीम से एकाधिक आउटपुट स्ट्रीम तक डेटा पाइप करने का सबसे अच्छा तरीका

Question

एक पाइपड इनपुटस्ट्रीम/पाइपडऑटपुटस्ट्रीम कनेक्शन बहुत अच्छा काम करता है जब डेटा को केवल एक आउटपुट में पाइप किया जाना चाहिए, लेकिन यदि एकाधिक आउटपुट स्ट्रीम एक इनपुट स्ट्रीम से जुड़े होते हैं, तो डेटा बन जाता है विभिन्न आउटपुट में खंडित। मेरे वर्तमान समाधान में एक थ्रेडेड "रीडर" होना शामिल है जो इनपुट इनपुट से डेटा पढ़ता है और फिर आउटपुटस्ट्रीम ऑब्जेक्ट्स को डेटा लिखता है जो पाठक से जुड़ा हुआ है। ऐसा लगता है कि यह ठीक काम करता है, लेकिन देशी PipedIO कक्षाओं की तुलना में यह गन्दा और अक्षम लगता है।

क्या इसे संभालने का कोई बेहतर तरीका है या यह कार्यान्वयन है कि मैं जितना अच्छा काम कर रहा हूं उतना अच्छा काम कर रहा हूं?

Answer 1

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

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

मुझे लगता है कि एकल इनपुट स्ट्रीम लगातार नहीं है (यानी डिस्क पर एक फ़ाइल) ... उस स्थिति में समाधान छोटा है।

Answer 2

पुरानी शैली कोड, this will give you a good starting place।