如何在python多处理池中使用关键字参数apply_async [英] how do I use key word arguments with python multiprocessing pool apply_async
问题描述
我正在尝试使用pythons多处理模块,特别是Pool
的apply_async方法.我正在尝试使用自变量和关键字自变量调用函数.如果我不使用kwargs调用该函数就可以了,但是当我尝试添加关键字参数时,我得到:
TypeError: apply_async() got an unexpected keyword argument 'arg2'
下面是我正在运行的测试代码
I'm trying to get to grips with pythons multiprocessing module, specifically the apply_async method of Pool
. I'm trying to call a function with arguments and keyword arguments. If I call the function without kwargs it's fine but when I try to add in a keyword argument I get:
TypeError: apply_async() got an unexpected keyword argument 'arg2'
Below is the test code that I'm running
#!/usr/bin/env python
import multiprocessing
from time import sleep
def test(arg1, arg2=1, arg3=2):
sleep(5)
if __name__ == '__main__':
pool = multiprocessing.Pool()
for t in range(1000):
pool.apply_async(test, t, arg2=5)
pool.close()
pool.join()
如何调用该函数以使其接受关键字参数?
How can I call the function so that it accepts keyword arguments?
推荐答案
在字典中传递关键字args(在元组中传递位置参数):
Pass the keyword args in a dictionary (and the positional arguments in a tuple):
pool.apply_async(test, (t,), dict(arg2=5))
这篇关于如何在python多处理池中使用关键字参数apply_async的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持IT屋!