实用程序
def exec_multiprocessing(self, method, args):
with concurrent.futures.ProcessPoolExecutor() as executor:
results = pool.map(method, args)
return results
clone.py
def clone_vm(self, name, first_run, host, ip):
# clone stuff
invoke.py
exec_args = [(name, first_run, host, ip) for host, ip in zip(hosts, ips)]
results = self.util.exec_multiprocessing(self.clone.clone_vm, exec_args)
上面的代码给出了酸洗错误。我发现这是因为我们正在传递实例方法。因此，我们应该解开实例方法。但是我无法使其工作。
注意：我无法创建顶级方法来避免这种情况。我必须使用实例方法。
python大神给出的解决方案
让我们从概述开始-为什么首先出现错误：
multiprocessing必须要求对数据进行腌制（序列化）以使其沿着进程或线程传递。具体来说，pool方法本身依赖于较低级别的queue来堆叠任务并将其传递给线程/进程，并且queue要求通过它的所有内容都必须是可拾取的。
问题是，并非所有项目都是可拾取的-list of pickables-并且当尝试对未拾取的对象进行腌制时，会得到PicklingError异常-正是您所遇到的情况，您传递了一个不可腌制的实例方法。
可以有多种解决方法（对于每个问题都是如此）-对我有用的解决方案是here by Dano-使pickle处理方法并将其注册到copy_reg。
在模块clone.py的开头添加以下行以使clone_vm可腌制（执行import copy_reg和types）：
def _pickle_method(m):
if m.im_self is None:
return getattr, (m.im_class, m.im_func.func_name)
else:
return getattr, (m.im_self, m.im_func.func_name)
copy_reg.pickle(types.MethodType, _pickle_method)
其他有用的答案-通过Alex Martelli，mrule，通过unutbu
如何获取Python中所有内置函数的列表 - python当我们从中获取关键字列表时，如何从Python提示符中获取Python中所有内置函数的列表？ python大神给出的解决方案 更新：关于__builtins__或__builtin__可能会有一些混淆。What’s New In Python 3.0建议使用builtins 将模块__builtin__重命名为builtins（删除下划线， 添加一个“ s”…
Python pytz时区函数返回的时区为9分钟 - python由于某些原因，我无法从以下代码中找出原因：>>> from pytz import timezone >>> timezone('America/Chicago') 我得到：<DstTzInfo 'America/Chicago' LMT-1 day, 18:09:00 STD…
Python:同时在for循环中添加到列表列表 - python我想用for循环外的0索引值创建一个新列表，然后使用for循环添加到相同的列表。我的玩具示例是：import random data = ['t1', 't2', 't3'] masterlist = [['col1', 'animal1', 'an…
用大写字母拆分字符串，但忽略AAA Python Regex - python我的正则表达式：vendor = "MyNameIsJoe. I'mWorkerInAAAinc." ven = re.split(r'(?<=[a-z])[A-Z]|[A-Z](?=[a-z])', vendor) 以大写字母分割字符串，例如：'我的名字是乔。 I'mWorkerInAAAinc”变成…
Python:来自dict系列的Pandas数据框 - python我有一个熊猫数据框：type(original) pandas.core.frame.DataFrame 其中包括系列对象original['user']：type(original['user']) pandas.core.series.Series original['user']指向许多命令：…