Articles of मल्टीप्रोसेसिंग

कई प्रक्रियाओं के बीच परिणाम कतार साझा करना

multiprocessing मॉड्यूल के लिए प्रलेखन दिखाता है कि multiprocessing.Process साथ शुरू की जाने वाली प्रक्रिया में कतार कैसे पारित किया जाए। multiprocessing.Process लेकिन मैं कैसे apply_async साथ शुरू एसिंक्रोनस कार्यकर्ता प्रक्रियाओं के साथ एक कतार साझा कर सकता हूँ? मुझे गतिशील जुड़ने या किसी और चीज की ज़रूरत नहीं है, केवल श्रमिकों के लिए (बार-बार) […]

पायथन मल्टीप्रोसेसिंग ग्लोबल वेरिएबल अपडेट नहीं लौटे हैं

मैं उपप्रक्रिया से मूल्यों को वापस करने की कोशिश कर रहा हूं, लेकिन ये मूल्य दुर्भाग्य से अनपेक्षित हैं इसलिए मैंने थ्रेड मॉड्यूल में ग्लोबल वैरिएबल को सफलतापूर्वक प्रयोग किया, लेकिन बहुप्रोसेसिंग मॉड्यूल का उपयोग करते समय उपप्रक्रिया में किए गए अद्यतनों को पुनः प्राप्त नहीं कर पाए हैं। मुझे आशा है कि मुझे कुछ […]

मल्टीप्रोसेसिंग: कक्षा में परिभाषित फ़ंक्शन पर पूल.मैप का उपयोग कैसे करें?

जब मैं कुछ ऐसा चलाता हूं: from multiprocessing import Pool p = Pool(5) def f(x): return x*x p.map(f, [1,2,3]) यह बढ़िया काम करता है। हालांकि, इसे एक वर्ग के फ़ंक्शन के रूप में लगाया जा रहा है: class calculate(object): def run(self): def f(x): return x*x p = Pool() return p.map(f, [1,2,3]) cl = calculate() print […]

पायथन में मल्टी प्रसंस्करण का उपयोग करते समय मुझे कैसे लॉग करना चाहिए?

अभी मेरे पास ढांचे में एक केंद्रीय मॉड्यूल है जो पायथन 2.6 multiprocessing मॉड्यूल का उपयोग करते हुए कई प्रक्रियाओं को पैदा करता है। क्योंकि यह multiprocessing का उपयोग करता है, वहां मॉड्यूल-स्तरीय मल्टीप्रोसेसिंग-अवगत लॉग, LOG = multiprocessing.get_logger() । दस्तावेज़ों के अनुसार , इस लॉगर में प्रक्रिया-साझा किए गए लॉक होते हैं ताकि आप चीजों […]

पायथन मल्टी प्रॉससेसिंग: मैं कई प्रक्रियाओं के बीच एक डिक्शनिस कैसे साझा करूं?

एक प्रोग्राम जो कई प्रक्रियाएं बनाता है जो कि एक सहभागी-योग्य कतार, Q पर काम करता है, और अंततः परिणामों को स्टोर करने के लिए एक वैश्विक शब्दकोश D को हेरफेर कर सकता है। (इसलिए प्रत्येक बच्चे की प्रक्रिया D का उपयोग इसके परिणाम को स्टोर करने के लिए और यह भी देख सकती है […]

बहु प्रसंस्करण: प्रक्रियाओं के बीच एक बड़े पढ़ने-योग्य ऑब्जेक्ट साझा करना?

क्या कार्यक्रम में पहले बनाई गई बहुप्रोसेसिंग शेयर ऑब्जेक्ट्स के माध्यम से उत्पन्न बच्चे की प्रक्रियाएं हैं? मेरे पास निम्न सेटअप है: do_some_processing(filename): for line in file(filename): if line.split(',')[0] in big_lookup_object: # something here if __name__ == '__main__': big_lookup_object = marshal.load('file.bin') pool = Pool(processes=4) print pool.map(do_some_processing, glob.glob('*.data')) मैं कुछ बड़े ऑब्जेक्ट को स्मृति में लोड […]

पायथन मल्टीप्रोसेसिंग पिकिंग त्रुटि

मुझे खेद है कि मैं एक सरल उदाहरण के साथ त्रुटि पुन: उत्पन्न नहीं कर सकता, और मेरा कोड पोस्ट करने के लिए बहुत जटिल है अगर मैं कार्यक्रम को अजगर थाने में नियमित अजगर के बजाय चलाता हूं, तो चीजें अच्छी तरह से काम करती हैं I मैंने इस समस्या पर कुछ पिछले नोट […]

मैं नॉनपी आयात करने के बाद केवल एक ही कोर का उपयोग क्यों करता है?

मुझे यकीन नहीं है कि यह एक ओएस मुद्दे के रूप में अधिक मायने रखता है या नहीं, लेकिन मैंने सोचा कि मैं यहाँ से पूछूंगा कि किसी के पास पायथन के कुछ चीजों से कुछ जानकारी है। मैं joblib का उपयोग करके पाश के for सीपीयू-भारी के समानांतर की कोशिश कर रहा joblib , […]

बहुप्रोसेसिंग के लिए साझा स्मृति में संख्यात्मक सरणी का उपयोग करें

मैं बहुप्रोसेसिंग मॉड्यूल के साथ साझा स्मृति में एक numpy सरणी का उपयोग करना चाहता हूं। कठिनाई यह एक numpy array की तरह प्रयोग कर रही है, और न कि सिर्फ एक सीटीपीसीएस सरणी के रूप में। from multiprocessing import Process, Array import scipy def f(a): a[0] = -a[0] if __name__ == '__main__': # Create […]

एकाधिक तर्कों के लिए पायथन मल्टीप्रोसेक्शन पूल.मैप

पायथन मल्टीप्रोसेसिंग लाइब्रेरी में, पूल का एक प्रकार है.मैप जो कई तर्कों का समर्थन करता है? text = "test" def harvester(text, case): X = case[0] return text+ str(X) if __name__ == '__main__': pool = multiprocessing.Pool(processes=6) case = RAW_DATASET pool.map(harvester(text,case),case, 1) pool.close() pool.join()

दिलचस्प पोस्ट
टी / टी को ओवरराइड किए बिना पासवर्ड कैसे पास करें? पर्ल 5 के फ़ंक्शन प्रोटोटाइप खराब क्यों हैं? बेस कन्स्ट्रक्टर को सी # में कॉल करना जीएमएम एसएमटीपी सर्वर से कनेक्ट होने के लिए जवामेल का उपयोग पोर्ट निर्दिष्ट करता है और 25 का इस्तेमाल करने की कोशिश करता है त्रुटि को ठीक कैसे करें: रूट तत्व के बाद दस्तावेज़ में मार्कअप को अच्छी तरह से बना होना चाहिए IllegalStateException: इस कार्रवाई को ViewPager के साथ सेवइन्स्टेंसस्टेट के बाद नहीं कर सकता ओआरए-00 9 18: कॉलम अस्पष्ट ढंग से चयन में परिभाषित * तालिका में लापता मूल्यों सहित () परिणामों में आर स्ट्रिंग को JSON सरणी में कनवर्ट करें क्रॉस-साइट AJAX अनुरोध Xcode 6 में स्टोरीबोर्ड में "मार्जिन पर नियंत्रण" क्या है एंड्रॉइड लेआउट वज़न "\ N" या '\ n' या std :: endl को std :: cout? Android में किसी अन्य गतिविधि को कॉल करने पर एनीमेशन कैसे प्रदान करें? मैं जावा में इंटरफ़ेस प्रोग्राम के सभी कार्यान्वयन की एक सूची कैसे प्राप्त करूं?