如何在python多处理池apply_async中使用关键字参数

Question

我正试图掌握pythons多处理模块,特别是apply_async方法Pool.我正在尝试使用参数和关键字参数调用函数.如果我在没有kwargs的情况下调用函数就可以了,但是当我尝试添加一个关键字参数时,我得到: TypeError: apply_async() got an unexpected keyword argument 'arg2' 下面是我正在运行的测试代码

#!/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()

如何调用该函数以使其接受关键​​字参数？

Answer 1

将关键字args传递给字典(以及元组中的位置参数):

pool.apply_async(test, (t,), dict(arg2=5))