因此,对于一个线程,超时参数应该在超时秒之后停止线程(如果它还没有终止)。
在我的软件中,我正在尝试替换Queue.Queue.join()(它包含每个线程的一个项目:每个线程将运行Queue.Queue.task_done())如果线程没有终止可能会停止软件。因此,如果一个线程(除其他50之外)没有终止,那么它就全部冻结了。
我希望每个线程在5秒内停止,例如。所以我将以超时5秒开始每个线程。这是对的吗?
码
import threading
import time
def tt(name, num):
while True:
num += 0.5
print 'thread ' + str(name) + ' at time ' + str(num)
time.sleep(0.5)
for i in range(3):
t=threading.Thread(target=tt, args=(i, 0))
t.setDaemon(True)
t.start()
t.join(timeout=1)
print 'end'
结果
它没有正常工作..每个线程应在1秒后停止。线程0在3秒后停止,线程1在2秒后停止。
thread 0 at time 0.5
thread 0 at time 1.0
thread 1 at time 0.5
thread 0 at time 1.5
thread 0 at time 2.0
thread 1 at time 1.0
thread 2 at time 0.5
thread 0 at time 2.5
thread 1 at time 1.5
thread 2 at time 1.0thread 1 at time 2.0
thread 0 at time 3.0
end
你误解了timeout
的作用。它只是告诉join
等待线程停止多长时间。如果线程在超时到期后仍在运行,则join
调用结束,但线程仍在运行。
来自文档:
当timeout参数存在而不是None时,它应该是一个浮点数,指定操作的超时(以秒为单位)(或其中的分数)。由于join()始终返回None,因此必须在join()之后调用isAlive()以确定是否发生超时 - 如果线程仍处于活动状态,则join()调用超时。