我有以下功能:
def copy_file(source_file, target_dir):
pass
现在我想用multiprocessing
立即执行此函数:
p = Pool(12)
p.map(lambda x: copy_file(x,target_dir), file_list)
问题是,lambda 不能被腌制,所以这失败了。解决这个问题最简洁的(Pythonic)方法是什么?
使用函数对象:
class Copier(object):
def __init__(self, tgtdir):
self.target_dir = tgtdir
def __call__(self, src):
copy_file(src, self.target_dir)
运行你的Pool.map
:
p.map(Copier(target_dir), file_list)
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)