在Python中的类中合并

Question

我想在一个类中使用Pool，但是似乎有问题。我的代码很长，我创建了一个小演示变量来说明问题。如果您能给我下面可行的代码变体，那就太好了。

from multiprocessing import Pool

class SeriesInstance(object):
    def __init__(self):
        self.numbers = [1,2,3]
    def F(self, x):
        return x * x
    def run(self):
        p = Pool()
        print p.map(self.F, self.numbers)


ins = SeriesInstance()
ins.run()

输出：

Exception in thread Thread-2:
Traceback (most recent call last):
  File "/usr/lib64/python2.7/threading.py", line 551, in __bootstrap_inner
    self.run()
  File "/usr/lib64/python2.7/threading.py", line 504, in run
    self.__target(*self.__args, **self.__kwargs)
  File "/usr/lib64/python2.7/multiprocessing/pool.py", line 319, in _handle_tasks
    put(task)
PicklingError: Can't pickle <type 'instancemethod'>: attribute lookup __builtin__.instancemethod failed

然后挂起。

Answer 1

看起来由于函数传递到工作线程（腌制）的方式的原因，您不能不幸地使用实例方法。我的第一个想法是使用lambda，但是事实证明，内置的pickler不能将它们序列化。可悲的是，解决方案只是在全局名称空间中使用一个函数。您仍然可以将其设置为实例属性，看一下：

from multiprocessing import Pool

def F(x):
    return x * x

class SeriesInstance(object):
    def __init__(self):
        self.numbers = [1,2,3]
        self.F = F

    def run(self):
        p = Pool()
        out = p.map(self.F, self.numbers)
        p.close()
        p.join()
        return out

if __name__ == '__main__':
    print SeriesInstance().run()