वैश्विक चर बदल रहा है जब अजगर में बहु

Question

तो क्या मैं अंत में करने के लिए कोशिश कर रहा हूँ एक पंक्ति पढ़ने के लिए है, कि लाइन में जानकारी के साथ कुछ गणना करते हैं, तो कुछ वैश्विक वस्तु के लिए परिणाम जोड़ने के लिए, लेकिन मैं इसे पाने के लिए प्रतीत नहीं कर सकते हैं काम करने के लिए। उदाहरण के लिए, नीचे दिए गए कोड में परीक्षण हमेशा 0 होता है। मुझे पता है कि यह गलत है, और मैंने इसे अन्य तरीकों से करने की कोशिश की है, लेकिन यह अभी भी काम नहीं कर रहा है।

import multiprocessing as mp 

File = 'HGDP_FinalReport_Forward.txt' 
#short_file = open(File) 
test = 0 

def pro(temp_line): 
    global test 
    temp_line = temp_line.strip().split() 
    test = test + 1 
    return len(temp_line) 

if __name__ == "__main__": 
    with open("HGDP_FinalReport_Forward.txt") as lines: 
     pool = mp.Pool(processes = 10) 
     t = pool.map(pro,lines.readlines()) 

Answer 1

पूल द्वारा उत्पन्न कार्यकर्ता प्रक्रियाओं को वैश्विक चर की अपनी प्रति प्राप्त करने और अद्यतन करने के लिए मिलता है। जब तक आप इसे स्पष्ट रूप से सेट नहीं करते हैं, तब तक वे स्मृति साझा नहीं करते हैं। सबसे आसान समाधान, test के अंतिम मूल्य मुख्य प्रक्रिया को वापस संवाद करने के लिए है जैसे वापसी मूल्य के माध्यम से। की तरह कुछ (अपरीक्षित):

def pro(temp_line): 
    test = 0 
    temp_line = temp_line.strip().split() 
    test = test + 1 
    return test, len(temp_line) 

if __name__ == "__main__": 
    with open("somefile.txt") as lines: 
     pool = mp.Pool(processes = 10) 
     tests_and_t = pool.map(pro,lines.readlines()) 
     tests, t = zip(*test_and_t) 
     test = sum(tests) 

Answer 2

यहाँ बहु के भीतर वैश्विक चर उपयोग करने के उदाहरण है।

हम स्पष्ट रूप से देख सकते हैं कि प्रत्येक प्रक्रिया चर की अपनी एक प्रतिलिपि के साथ काम करता है:

import multiprocessing 
import time 
import os 
import sys 
import random 
def worker(a): 
    oldValue = get() 
    set(random.randint(0, 100)) 
    sys.stderr.write(' '.join([str(os.getpid()), str(a), 'old:', str(oldValue), 'new:', str(get()), '\n'])) 

def get(): 
    global globalVariable 
    return globalVariable 

globalVariable = -1 
def set(v): 
    global globalVariable 
    globalVariable = v 

print get() 
set(-2) 
print get() 

processPool = multiprocessing.Pool(5) 
results = processPool.map(worker, range(15)) 

आउटपुट:

27094 0 old: -2 new: 2 
27094 1 old: 2 new: 95 
27094 2 old: 95 new: 20 
27094 3 old: 20 new: 54 
27098 4 old: -2 new: 80 
27098 6 old: 80 new: 62 
27095 5 old: -2 new: 100 
27094 7 old: 54 new: 23 
27098 8 old: 62 new: 67 
27098 10 old: 67 new: 22 
27098 11 old: 22 new: 85 
27095 9 old: 100 new: 32 
27094 12 old: 23 new: 65 
27098 13 old: 85 new: 60 
27095 14 old: 32 new: 71