如何让Pool.map接受lambda函数 [英] How to let Pool.map take a lambda function

问题描述

我具有以下功能:

def copy_file(source_file, target_dir):
    pass

现在，我想使用multiprocessing一次执行此功能:

Now I would like to use multiprocessing to execute this function at once:

p = Pool(12)
p.map(lambda x: copy_file(x,target_dir), file_list)

问题是，不能腌制lambda，因此失败了.解决此问题的最简洁的方法是什么?

The problem is, lambda's can't be pickled, so this fails. What is the most neat (pythonic) way to fix this?

推荐答案

使用函数对象:

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)

这篇关于如何让Pool.map接受lambda函数的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！