在python中使用joblib进行并行处理时，对象属性似乎没有变化。
在python中使用joblib进行并行处理时，对象属性似乎没有变化。
提问于 2018-09-12 08:06:54
我有以下代码，可以很好地处理一个进程，但不能处理多个进程。没有错误消息，但类属性似乎没有保存，我不知道为什么或如何修复它。我在windows下运行代码。
class T:
a = 0
b = 0
c = 0
def do_something(self):
self.a = 10
self.b = 5
self.c = 1
return 'ok'
def call_T(a):
return a.do_something()
if __name__ == '__main__':
B = T()
print(B.a)
B.do_something()
print(B.a)
C = [T() for i in range(20)]
print(C[14].c)
F = Parallel(n_jobs=2)(delayed(call_T)(C[i]) for i in range(20))
print(F)
print(C[14].b)结果是
0
10
0
['ok', 'ok', 'ok', 'ok', 'ok', 'ok', 'ok', 'ok', 'ok', 'ok', 'ok', 'ok', 'ok', 'ok', 'ok', 'ok', 'ok', 'ok', 'ok', 'ok']
0现在，对于相同的代码，只需更改n_jobs=1，它就会给出正确的预期结果
0
10
0
['ok', 'ok', 'ok', 'ok', 'ok', 'ok', 'ok', 'ok', 'ok', 'ok', 'ok', 'ok', 'ok', 'ok', 'ok', 'ok', 'ok', 'ok', 'ok', 'ok']
5我对哪里出了问题一无所知。任何帮助我们都将不胜感激
回答 1
Stack Overflow用户
发布于 2018-09-12 08:30:14
我发现了一个简单的答案，那就是joblib只传递返回方法的结果，而不是使用线程的内存，但是两者都会传递。
class T:
a = 0
b = 0
c = 0
def do_something(self):
self.a = 10
self.b = 5
self.c = 1
return 'ok'
def call_T(a):
return a.do_something()
if __name__ == '__main__':
B = T()
print(B.a)
B.do_something()
print(B.a)
C = [T() for i in range(20)]
print(C[14].c)
F = Parallel(n_jobs=3,backend="threading")(delayed(call_T)(C[i]) for i in range(20))
print(F)
print(C[14].b)结果
0
10
0
['ok', 'ok', 'ok', 'ok', 'ok', 'ok', 'ok', 'ok', 'ok', 'ok', 'ok', 'ok', 'ok', 'ok', 'ok', 'ok', 'ok', 'ok', 'ok', 'ok']
5页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/52285688
复制相关文章
相似问题