Python 多处理 - 如何将 kwargs 传递给函数?

问题描述 投票:0回答:2

如何使用 Python 的多重处理将字典传递给函数?文档:https://docs.python.org/3.4/library/multiprocessing.html#reference说要传递字典,但我不断得到

TypeError: fp() got multiple values for argument 'what'

这是代码:

from multiprocessing import Process, Manager
   
def fp(name, numList=None, what='no'):
        print ('hello %s %s'% (name, what))
        numList.append(name+'44')
 
if __name__ == '__main__':

    manager = Manager()
 
    numList = manager.list()
    for i in range(10):
        keywords = {'what':'yes'}
        p = Process(target=fp, args=('bob'+str(i)), kwargs={'what':'yes'})
        p.start()
        print("Start done")
        p.join()
        print("Join done")
    print (numList)
python multiprocessing keyword-argument
2个回答
30
投票

当我运行你的代码时,我得到了一个不同的错误:

TypeError: fp() takes at most 3 arguments (5 given)

我通过打印 args 和 kwargs 并将方法更改为

fp(*args, **kwargs)
进行调试,并注意到“bob_”作为字母数组传入。看起来用于
args
的括号是可操作的,实际上并没有给你一个元组。将其更改为列表,然后还传入
numList
作为关键字参数,使代码对我有用。

from multiprocessing import Process, Manager

def fp(name, numList=None, what='no'):
    print ('hello %s %s' % (name, what))
    numList.append(name+'44')

if __name__ == '__main__':

    manager = Manager()

    numList = manager.list()
    for i in range(10):
        keywords = {'what': 'yes', 'numList': numList}
        p = Process(target=fp, args=['bob'+str(i)], kwargs=keywords)
        p.start()
        print("Start done")
        p.join()
        print("Join done")
    print (numList)

0
投票

您缺少一个逗号:

args=('bob'+str(i)) -> args=('bob'+str(i), )
,否则 Python 会将表达式识别为元组。

© www.soinside.com 2019 - 2024. All rights reserved.