问题描述
我正在尝试掌握 python 的多处理模块,特别是 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))