如何在 Python 的多处理池中使用类方法？

Question

我提出了一个简单的玩具问题，但潜在的问题是如何在 Python 的多处理池中使用类方法？

class Var:
    
    def __init__(self,val):
        self.val = val
        
    def increment(self):
        self.val +=1 
        
arr = [Var(1) for i in range(1000)]        
def func(x):
    x.increment()

with Pool() as pool:
    results = pool.map(func, arr)

返回的结果是一组None 值。我希望这是因为 func 没有返回任何内容。但是，arr[0] 仍然设置为 1。它没有递增。当然，我可以让方法返回新值。但这不是我正在寻找的解决方案。应该更新对象。

归根结底，我需要并行处理对象。有没有其他方法可以在 Python 中完成？

Answer 1

你写了

def func(x):
    x.increment()

你想写

def func(x: Var) -> int:
    x.increment()
    return x.val

因此它将在孩子中序列化并在父母中接收回来。

---

我需要并行处理对象。

就“工作”递增整数而言， 在 cPython 解释器下使用此模块是不可行的， 因为序列化/反序列化的成本将主导任何应用程序级别的工作。

就“工作”是其他一些 CS 任务而言， 你提出了一个 XY 问题。 你问我们关于“X”的话题，你已经知道答案 对回应感到不满。 它消耗了你和我们的时间。 也许现在您准备好向我们询问“Y”了。