使用多进程Pool.map()时无法pickle <type 'instancemethod'>开发者社区

link之家

链接快照平台

输入网页链接，自动生成快照
标签化管理网页链接

相关文章推荐

长情的电池 · 罗马大师赛：辛纳解禁复出首战告捷-新华网· 昨天 ·

坚强的领结 · 老照片：袁世凯手下最得力的13员武将，图二段 ...· 12 月前 ·

细心的佛珠 · 调查称夜店吹气球实为吸“笑气” 过量能致命-新华网· 12 月前 ·

高兴的硬币 · 金斯瑞生物科技2020全球校园招聘简章· 1 年前 ·

内向的花卷 · 出汗的10大惊人好处！· 1 年前 ·

腾讯云

开发者社区

文档意见反馈控制台

首页 TVP

最新优惠活动

文章/答案/技术大牛

发布

import multiprocessing
def f(x):
    return x*x
def go():
    pool = multiprocessing.Pool(processes=4)        
    print pool.map(f, range(10))
if __name__== '__main__' :
    go()

PicklingError: Can't pickle <type 'instancemethod'>: attribute lookup
__builtin__.instancemethod failed

import someClass
if __name__== '__main__' :
    sc = someClass.someClass()
    sc.go()

import multiprocessing
class someClass(object):
    def __init__(self):
    def f(self, x):
        return x*x
    def go(self):
        pool = multiprocessing.Pool(processes=4)       
        print pool.map(self.f, range(10))

>>> import pathos.pools as pp
>>> p = pp.ProcessPool(4)
>>> def add(x,y):
...   return x+y
>>> x = [0,1,2,3]
>>> y = [4,5,6,7]
>>> p.map(add, x, y)
[4, 6, 8, 10]
>>> class Test(object):
...   def plus(self, x, y): 
...     return x+y
>>> t = Test()
>>> p.map(Test.plus, [t]*4, x, y)
[4, 6, 8, 10]
>>> p.map(t.plus, x, y)
[4, 6, 8, 10]

>>> import pathos.pools as pp
>>> class someClass(object):
...   def __init__(self):
...     pass
...   def f(self, x):
...     return x*x
...   def go(self):
...     pool = pp.ProcessPool(4)

回答 12

Stack Overflow用户

Stack Overflow用户