0

在尝试创建线程时,我无法将星号表达式与固定参数列表结合使用。

考虑以下代码:

the_queue = Queue()

def do_something(arg1, arg2, queue):
    # Do some stuff...
    result = arg1 + arg2

    queue.put(result)

def init_thread(*arguments):
    t = Thread(target=do_something, args=(arguments, the_queue))
    t.start()
    t.join()

init_thread(3,6)

这会引发异常:

TypeError: do_something() takes exactly 3 arguments (2 given)

换句话说,“参数”元组被评估为一个元组对象(即它没有被解包),而 the_queue 被视为第二个参数。

代码需要能够初始化调用具有未知数量参数的不同方法的线程,但最后总是会有一个“队列”参数。

有什么办法可以做到这一点?在那种情况下,怎么办?如果不是 - 我做错了什么?

谢谢。

编辑:我应该补充一点,以队列作为参数调用“init_thread()”方法不是一个选项,因为我不希望我的其余代码“知道”线程处理程序在内部是如何工作的。 .

4

2 回答 2

1

你需要制作一个新的tuple.

t = Thread(target = do_something, args = arguments + (the_queue, ))
于 2012-07-09T21:33:53.233 回答
1

您还可以解压缩打包的 *arguments 元组,如下所示:

>>> def Print(*args):
...     print('I am prepended to every message!', *args)
... 
>>> Print('This', 'has', 'four', 'arguments')
I am prepended to every message! This has four arguments
>>> def Print(*args):
...     print('I am prepended to every message!', args)
... 
>>> Print('This', 'has', 'four', 'arguments')
I am prepended to every message! ('This', 'has', 'four', 'arguments')

所以你看,引用 *agruments,而不是参数,将解包元组。因此,您的代码可能是:

def init_thread(*arguments):  
    t = Thread(target=do_something, args=(*arguments, the_queue))
    t.start()
    t.join()
于 2012-07-09T23:26:02.013 回答