मैं प्रक्रियाओं के बीच कक्षा कैसे साझा कर सकता हूं?

Question

मैं वैश्विक ऑब्जेक्ट रखना चाहता हूं जो न्यूनतम प्रक्रियाओं के साथ सभी प्रक्रियाओं द्वारा साझा और अद्यतन किया जाता है।

import multiprocessing 

class Counter(object): 
    def __init__(self): 
    self.value = 0 

    def update(self, value): 
    self.value += value 


def update(counter_proxy, thread_id): 
    counter_proxy.value.update(1) 
    print counter_proxy.value.value, 't%s' % thread_id, \ 
    multiprocessing.current_process().name 
    return counter_proxy.value.value 

def main(): 
    manager = multiprocessing.Manager() 
    counter = manager.Value(Counter, Counter()) 
    pool = multiprocessing.Pool(multiprocessing.cpu_count()) 
    for i in range(10): 
    pool.apply(func = update, args = (counter, i)) 
    pool.close() 
    pool.join() 

    print 'Should be 10 but is %s.' % counter.value.value 

if __name__ == '__main__': 
    main() 

परिणाम यह है - 10 नहीं बल्कि शून्य। ऐसा लगता है कि ऑब्जेक्ट का साझा मूल्य अपडेट नहीं किया गया है। मैं इस तरह के मूल्य को कैसे लॉक और अपडेट कर सकता हूं?

0 t0 PoolWorker-2 
0 t1 PoolWorker-3 
0 t2 PoolWorker-5 
0 t3 PoolWorker-8 
0 t4 PoolWorker-9 
0 t5 PoolWorker-2 
0 t6 PoolWorker-7 
0 t7 PoolWorker-4 
0 t8 PoolWorker-6 
0 t9 PoolWorker-3 
Should be 10 but is 0. 

---

वर्तमान @dano द्वारा सबसे अच्छा समाधान - मैं कक्षा प्रॉक्सी के साथ कस्टम प्रबंधक मिलाया।

import multiprocessing 
from multiprocessing.managers import BaseManager, NamespaceProxy 


class Counter(object): 
    def __init__(self): 
    self.value = 0 

    def update(self, value): 
    self.value += value 


def update(counter_proxy, thread_id): 
    counter_proxy.update(1) 

class CounterManager(BaseManager): 
    pass 

class CounterProxy(NamespaceProxy): 
    _exposed_ = ('__getattribute__', '__setattr__', '__delattr__', 'update') 

    def update(self, value): 
    callmethod = object.__getattribute__(self, '_callmethod') 
    return callmethod(self.update.__name__, (value,)) 

CounterManager.register('Counter', Counter, CounterProxy) 

def main(): 
    manager = CounterManager() 
    manager.start() 

    counter = manager.Counter() 
    pool = multiprocessing.Pool(multiprocessing.cpu_count()) 
    for i in range(10): 
    pool.apply(func = update, args = (counter, i)) 
    pool.close() 
    pool.join() 

    print 'Should be 10 but is %s.' % counter.value 

if __name__ == '__main__': 
    main() 

Answer 1

multiprocessing.Value कस्टम वर्गों के साथ इस्तेमाल किया जा करने के लिए नहीं है, यह एक multiprocessing.sharedctypes.Value के समान होने की अपेक्षा की जाती है। इसके बजाय, आपको custom manager बनाने की आवश्यकता है और इसके साथ अपनी कक्षा पंजीकृत करें। यदि आप सीधे value तक पहुंच नहीं पाते हैं, लेकिन विधियों के माध्यम से इसे संशोधित/एक्सेस नहीं करते हैं, तो डिफ़ॉल्ट रूप से आपकी कक्षा के लिए बनाए गए डिफ़ॉल्ट Proxy द्वारा निर्यात किया जाएगा। नियमित गुण (जैसे Counter.value) नहीं हैं, इसलिए वे अतिरिक्त अनुकूलन के बिना पहुंच योग्य नहीं हैं। यहाँ एक काम कर उदाहरण है:

import multiprocessing 
from multiprocessing.managers import BaseManager 

class MyManager(BaseManager): pass 

def Manager(): 
    m = MyManager() 
    m.start() 
    return m 

class Counter(object): 
    def __init__(self): 
    self._value = 0 

    def update(self, value): 
    self._value += value 

    def get_value(self): 
     return self._value 

MyManager.register('Counter', Counter) 

def update(counter_proxy, thread_id): 
    counter_proxy.update(1) 
    print counter_proxy.get_value(), 't%s' % thread_id, \ 
    multiprocessing.current_process().name 
    return counter_proxy 

def main(): 
    manager = Manager() 
    counter = manager.Counter() 
    pool = multiprocessing.Pool(multiprocessing.cpu_count()) 
    for i in range(10): 
    pool.apply(func=update, args=(counter, i)) 
    pool.close() 
    pool.join() 

    print 'Should be 10 but is %s.' % counter.get_value() 

if __name__ == '__main__': 
    main() 

आउटपुट:

1 t0 PoolWorker-2 
2 t1 PoolWorker-8 
3 t2 PoolWorker-4 
4 t3 PoolWorker-5 
5 t4 PoolWorker-6 
6 t5 PoolWorker-7 
7 t6 PoolWorker-3 
8 t7 PoolWorker-9 
9 t8 PoolWorker-2 
10 t9 PoolWorker-8 
Should be 10 but is 10.