我现在正在使用Python。我有一个start-function
,从消息中获取字符串。我想为每条消息启动线程。
目前的线程应该像这样打印出我的消息:
def startSuggestworker(message):
print(message)
def start():
while True:
response = queue.receive_messages()
try:
message = response.pop()
start_keyword = message.body
t = threading.Thread(target=startSuggestworker, args = (start_keyword))
t.start()
message.delete()
except IndexError:
print("Messages empty")
sleep(150)
start()
此刻我得到了TypeError
并且不明白为什么。异常消息是这样的:
Exception in thread Thread-1:
Traceback (most recent call last):
File "/Library/Frameworks/Python.framework/Versions/3.5/lib/python3.5/threading.py", line 914, in _bootstrap_inner
self.run()
File "/Library/Frameworks/Python.framework/Versions/3.5/lib/python3.5/threading.py", line 862, in run
self._target(*self._args, **self._kwargs)
TypeError: startSuggestworker() takes 1 positional argument but y were given
*y = 我的字符串的长度
我究竟做错了什么?
The args
夸格的threading.Thread
需要一个可迭代对象,并且该可迭代对象中的每个元素都被传递给目标函数。
由于您提供了一个字符串args
:
t = threading.Thread(target=startSuggestworker, args=(start_keyword))
每个字符都作为单独的参数传递给startSuggestworker
.
相反,您应该提供args
一个元组:
t = threading.Thread(target=startSuggestworker, args=(start_keyword,))
# ^ note the comma
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)