Nondeterministically इंटरलिविंग नाली के सूत्रों का कहना है

Question

मैं की तरह

interleave :: WhateverIOMonadClassItWouldWant m => [(k, Source m a)] -> Source m (k, a) 

उपयोग के मामले में प्रकार हस्ताक्षर के साथ स्रोतों के लिए एक गैर नियतात्मक इंटरलिविंग आपरेशन को देखने के लिए, उम्मीद थी कि मैं एक p2p अनुप्रयोग है कि पर कई नोड्स के लिए खुला सम्बन्ध बनाये रखते है नेटवर्क, और यह ज्यादातर उनमें से किसी के संदेशों के इंतजार के आसपास बस बैठे हैं। जब कोई संदेश आता है, तो यह परवाह नहीं करता कि यह कहां से आया था, लेकिन जितनी जल्दी हो सके संदेश को संसाधित करने की आवश्यकता है। सिद्धांत रूप में इस तरह के आवेदन (कम से कम जब सॉकेट जैसी स्रोतों के लिए उपयोग किया जाता है) जीएचसी के आईओ मैनेजर को पूरी तरह से बाईपास कर सकता है और select/epoll/आदि चला सकता है। सीधे कॉल करता है, लेकिन जब तक यह काम करता है, तब तक मुझे विशेष रूप से परवाह नहीं है कि यह कैसे कार्यान्वित किया जाता है।

क्या यह कंड्यूट के साथ ऐसा कुछ संभव है? एक कम सामान्य लेकिन शायद अधिक व्यवहार्य दृष्टिकोण [(k, Socket)] -> Source m (k, ByteString) फ़ंक्शन लिखना हो सकता है जो आपके लिए सभी सॉकेट पर प्राप्त करता है।

मैं नाली में ResumableSource संचालन देखा, लेकिन वे सभी एक विशेष Sink है, जो इस कार्रवाई के लिए एक अमूर्त रिसाव का एक सा की तरह लगता है, कम से कम के बारे में पता होना चाहता हूँ करने लगते हैं।

Answer 1

एसटीएम-कंडिट पैकेज mergeSources प्रदान करता है जो कुछ समान करता है- हालांकि समान नहीं है- जो आप खोज रहे हैं। यह शुरू करने के लिए शायद एक अच्छी जगह है।

Answer 2

हां, यह संभव है।

आप धागे forking जहां प्रत्येक सूत्र में आप एक Sink कि कुछ संगामिति चैनल में आउटपुट भेजता है के साथ Source जोड़ी सर्वेक्षण करना द्वारा रोके बिना Source रों का एक समूह मतदान कर सकते हैं:

concur :: (WhateverIOMonadClassItWouldWant m) => TChan a -> Sink a m r 

... और फिर आप एक Source कि उस चैनल से पढ़ता निर्धारित करें:

synchronize :: (WhateverIOMonadClassItWouldWant m) => TChan a -> Source a m r 

सूचना कि यह सिर्फ सॉकेट खुद को मतदान पर धागे forking से अलग नहीं होगा, लेकिन यह conduit के अन्य उपयोगकर्ताओं के लिए उपयोगी होगा जो Source एस का उपयोग करके सॉकेट की तुलना में अन्य चीजों को मतदान करना चाहेंगे क्योंकि यह अधिक सामान्य है।

आप एक समारोह में उन क्षमताओं संयुक्त है, तो कॉल के समग्र एपीआई कुछ ऐसा दिखाई देगा:

poll :: (WhateverIOMonadClassItWouldWant m) => [Source a m r] -> m (Source a m r) 

... लेकिन आप अभी भी उन k रों में फेंक अगर आप चाहते हैं कर सकते हैं।