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

link之家

链接快照平台

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

文章/答案/技术大牛

发布

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)

推荐文章

耍酷的炒饭 · access的一张表，最多可以容纳多少条记录_百度知道

1 年前

率性的羽毛球 · RxJava2 实战知识梳理(5) - 简单及进阶的轮询操作-腾讯云开发者社区-腾讯云

1 年前

老实的显示器 · 分析 Azure Monitor 日志中的文本数据 - Azure Monitor | Microsoft Learn

1 年前

笑点低的毛豆 · rxjava有点 rxjava delay_mob6454cc73e9a6的技术博客_51CTO博客

1 年前

要出家的伤疤 · R语言将dataframe的数据列从字符串类型转换为因子类型（from character vector to factor vector） - 知乎

1 年前

回答 12

Stack Overflow用户

Stack Overflow用户