0
当它被卡在while循环中时,是否可以过早地停止线程?以下是我的示例代码,它正确运行,因为每次调用loop_thread
它都会检查threading.Event()
标志是否已设置。当试图运行处理信息的文件的代码比每秒更长时,无法停止整个函数继续执行,直到下一次迭代。例如,如果我运行dld_img_thread
,则需要大约5分钟才能完成其执行并重新检查while循环以查看是否应继续。我想要发生的是在短于5分钟的时间(例如1分钟)杀死dld_img_thread
。我不在乎数据是否丢失,只是线程在函数完成执行之前停止。谢谢导致线程停留在while循环内时停止?
import threading, time, pythoncom, read_mt0
import powerfail_debugport_reader as pf_dbg_rdr
import powerfail_firmware_downloader as pf_fwdld
def loop_thread(thread_name, thread_event):
loopCnt = 0
print "\nstarting {}".format(thread_name)
print "is {0} alive? {1}\n".format(thread_name, L00P_thread.is_alive())
while not thread_event.is_set():
print("value of loopCnt = {}".format(loopCnt))
loopCnt += 1
time.sleep(1)
print('stopping {}\n'.format(thread_name))
def image_dld(thread_name, thread_event):
pythoncom.CoInitializeEx(pythoncom.COINIT_MULTITHREADED)
print "\nstarting {}".format(thread_name)
print "is {0} alive? {1}\n".format(thread_name, dld_img_thread.is_alive())
while not thread_event.is_set():
pf_fwdld.power_fail_test()
print('stopping {}'.format(thread_name))
def debug_port_thread(thread_name, thread_event):
pythoncom.CoInitializeEx(pythoncom.COINIT_MULTITHREADED)
print "\nstarting {}".format(thread_name)
print "is {0} alive? {1}\n".format(thread_name, debug_thread.is_alive())
pf_dbg_rdr.debug_port_reader()
print('\nstopping {}'.format(thread_name))
def main():
global L00P_thread, debug_thread
pf_dbg_rdr.samurai_event = threading.Event()
L00P_thread = threading.Thread(target=loop_thread, \
args=('L00P_thread', pf_dbg_rdr.samurai_event))
dld_img_thread = threading.Thread(target=image_dld, \
args=('image_download', pf_dbg_rdr.samurai_event))
debug_thread = threading.Thread(target=debug_port_thread, \
args=('debug_port_reader', pf_dbg_rdr.samurai_event))
L00P_thread.start()
dld_img_thread.start()
debug_thread.start()
debug_thread.join()
if __name__ == '__main__':
main()
print('processes stopped')
print "Exiting Main Thread"
对于循环线程来说工作正常,但对于另一个线程来说,这个过程将不起作用。我在一个外部函数中设置了一个标志,它应该停止另一个线程,但它只会在整个函数完成执行后才起作用。 –
对不起,没有发现。我一次尝试做太多事情是我的错。 – peteredhead