Python multiprocessing mit pathos

Ich bin der pathos Autor. Ich bin mir nicht sicher, was Sie tun möchten, aus dem code oben.
Allerdings kann ich vielleicht etwas Licht. Hier einige ähnliche code:

>>> from pathos.multiprocessing import ProcessingPool
>>> class Bar:
...   def foo(self, name):
...     return len(str(name))
...   def boo(self, things):
...     for thing in things:
...       self.sum += self.foo(thing)
...     return self.sum
...   sum = 0
... 
>>> b = Bar()
>>> results = ProcessingPool().map(b.boo, [[12,3,456],[8,9,10],['a','b','cde']])
>>> results
[6, 4, 5]
>>> b.sum
0

So was passiert, vor, ist, dass die boo Methode der Bar Instanz b aufgerufen, wo b.boo übergeben wird, eine neue python-Prozess und anschließend ausgewertet, für jede der geschachtelten Listen. Sie können sehen, dass die Ergebnisse richtig sind... len("12")+len("3")+len("456") ist 6, und so weiter.

Aber Sie können auch sehen, dass wenn man sich b.sum es auf mysteriöse Weise immer noch 0. Warum ist b.sum noch null? Naja, was multiprocessing (und damit auch pathos.multiprocessing) tut, ist eine KOPIEREN, was Sie Durchlaufen die Karte, um die anderen python-Prozess... und dann die kopierte Instanz wird dann als (parallel) und zurück, was auch immer Ergebnisse genannt werden, die von der Methode aufgerufen wird. Hinweis: Sie müssen ZURÜCK Ergebnisse oder drucken Sie Sie, oder melden Sie Sie, oder senden Sie eine Datei oder sonst. Sie können nicht zurück auf die ursprüngliche Instanz als man erwarten könnte, denn es ist nicht der original-Instanz, die geschickt über zu den anderen Prozessoren. Die Kopien der Instanz erstellt, die dann entsorgt werden-jede von Ihnen hatte Ihre sum Attribut erhöht, aber das original `b.Summe' ist unberührt.

Gibt es jedoch, die Pläne innerhalb von pathos etwas zu machen, wie die oben genannten arbeiten, wie man erwarten könnte-wo das ursprüngliche Objekt IST aktualisiert, aber es funktioniert so nicht, dass noch.

EDIT: Wenn Sie die Installation mit pip beachten Sie, dass die Letzte veröffentlichte version von pathos ist mehrere Jahre alt und wird möglicherweise nicht ordnungsgemäß installiert oder kann nicht installieren Sie alle Submodule. Eine neue pathos release ansteht, aber bis dahin, ist es besser, die neueste version des code von github, und von dort installieren. Der Rumpf ist zum größten Teil stabil in der Entwicklung. Ich denke, dein Problem könnte gewesen sein, dass nicht alle Pakete installiert wurden, durch eine "neue" pip -- "alten" pathos Inkompatibilität in der Installation. Wenn pathos.multiprocessing fehlt, ist dies die wahrscheinlichste Ursache.

Bekommen pathos von github hier: https://github.com/uqfoundation/pathos