15

我有一个接受多个参数的函数,其中一些是布尔值。我正在尝试将其传递给多处理pool.apply_async并希望传递一些带有附加名称的参数。

这是我正在使用的示例脚本:

from multiprocessing import Pool

    def testFunc(y, x, calcY=True):
        if calcY == True:
            return y*y
        elif calcY == False:
            return x*x

    if __name__ == "__main__":
        p = Pool()
        res = p.apply_async(testFunc, args = (2, 4, False))
        print res.get()

这可行,但我很好奇将其更改为res = p.apply_async(testFunc, args = (2, 4, False))

res = p.apply_async(testFunc, args = (2, 4, calcY = False))
4

1 回答 1

24

apply_async具有argskwds关键字参数,您可以像这样使用它们:

res = p.apply_async(testFunc, args=(2, 4), kwds={'calcY': False})
于 2012-09-18T18:26:28.610 回答