Detener un hilo después de un cierto período de tiempo

Question

Estoy buscando terminar algunos hilos después de un cierto período de tiempo. Estos subprocesos se ejecutarán en un bucle while infinito y durante este tiempo pueden bloquearse durante un gran período de tiempo al azar. El hilo no puede durar más que el tiempo establecido por la variable de duración. ¿Cómo puedo hacer para que después de la duración establecida por la duración, los hilos se detengan.

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

Esto funcionará si que no está bloqueando.

Si está planeando dormir, es absolutamente imprescindible que use el evento para dormir. Si aprovecha el evento para dormir, si alguien le dice que se detenga mientras "duerme", se despertará. Si usa time.sleep() su hilo solo se detendrá después de se despierta.

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

si desea que los hilos que se detienen cuando las salidas del programa (como lo implica su ejemplo), entonces los hacen daemon threads.

Si quieres que tus hilos mueran por orden, entonces tienes que hacerlo a mano. Hay varios métodos, pero todos implican hacer una verificación en el ciclo de su hilo para ver si es el momento de salir (vea el ejemplo de Nix).