导致线程停留在while循环内时停止？

当它被卡在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"

来源

2017-04-03 nice_remark

使用您的病情，而第二个变量一旦达到你的超时，你可以改变。

例如：

shouldRun = True 
while not thread_event.is_set() and shouldRun: 
    print("value of loopCnt = {}".format(loopCnt)) 
    loopCnt += 1 
    time.sleep(1) 
    if loopCnt > 60: shouldRun = False

后60次迭代会停止（约60秒给你睡在每次迭代1秒）。

来源

2017-04-03 15:51:28 peteredhead

对于循环线程来说工作正常，但对于另一个线程来说，这个过程将不起作用。我在一个外部函数中设置了一个标志，它应该停止另一个线程，但它只会在整个函数完成执行后才起作用。 –

对不起，没有发现。我一次尝试做太多事情是我的错。 – peteredhead

导致线程停留在while循环内时停止？

回答

相关问题