在一段時間後停止線程

Question

我期望在一段時間後終止一些線程。這些線程將運行一個無限的while循環，在此期間，它們可能會隨機拖延大量時間。線程的持續時間不能超過持續時間變量設置的時間。 如何在持續時間設定的長度後使線程停止。

def main(): 
    t1 = threading.Thread(target=thread1, args=1) 
    t2 = threading.Thread(target=thread2, args=2) 

    time.sleep(duration) 
    #the threads must be terminated after this sleep 

Answer 1

這將工作如果未擋住。

如果您打算睡覺，那麼您絕對需要使用該事件來進行睡眠。如果你利用這個事件進行睡眠，如果有人告訴你在「睡覺」時停下來，它會醒來。如果你使用time.sleep()，你的線程只會在醒來後停止。

def main(): 
    t1_stop= threading.Event() 
    t1 = threading.Thread(target=thread1, args=(1, t1_stop)) 

    t2_stop = threading.Event() 
    t2 = threading.Thread(target=thread2, args=(2, t2_stop)) 

    time.sleep(duration) 
    #stop the thread2 
    t2_stop.set() 

def thread1(arg1, stop_event): 
    while(not stop_event.is_set()): 
     #similar to time.sleep() 
     stop_event.wait(time) 
     pass 


def thread2(arg1, stop_event): 
    while(not stop_event.is_set()): 
     stop_event.wait(time) 
     pass 

Answer 2

如果你想線程停止當你的程序退出（如暗示你的榜樣），然後讓他們daemon threads。

如果你想要你的線程死於命令，那麼你必須手工完成。有各種方法，但都涉及在你的線程循環中檢查是否有時間退出（參見Nix的例子）。