[Resuelto] problema con hilos (malditos hilos en python xD)

[theteam]

el tema es asi, necesito que un hilo se inicie y se pare en diversas partes del programa. como deben saber python no tiene un buen manejo de hilos (por lo que lei por toda internet) con lo que por ejemplo no se puede parar un hilo desde fuera del hilo.
al parar el hilo (con un bucle como lei en varios lados) y al volverlo a iniciar, me tira un error diciendo de que el hilo ya esta iniciado, incluso poniendole un if not hilo.isAlive()

aca un codigo simplificado:

Código:

import sys
import os
import threading, time

class MainWindow():
    
    def __init__(self):
        # t es un hilo
        self.t = threading.Thread(target=self.hilo)
        #como python no brinda una forma de parar ciclos desde afuera necesitamos una variable :S, pero bueh
        self.parar=True
        print "creo hilo por primera vez"
        self.crearHilo()
        print "creo un hilo sin parar el anterior"
        self.crearHilo()
        print "paro el hilo, espero 5 seg y vuelvo a crear"
        self.parar=True
        time.sleep(5)
        self.crearHilo()
    
    def crearHilo(self):
        if self.t.isAlive():
            print "hilo activo, no inicio"
        else:
            self.parar=False
            print "hilo desactivado, inicio"
            self.t.start()
    
    def hilo(self):
        while (not self.parar):
            print "se esta ejecutando el hilo"
            time.sleep(2)
        return

if __name__ == "__main__":
    oa=MainWindow()

me imprime esto la consola cuando lo ejecuto:

Código:

creo hilo por primera vez
hilo desactivado, inicio
se esta ejecutando el hilo
 creo un hilo sin parar el anterior
hilo activo, no inicio
paro el hilo, espero 3 seg y vuelvo a crear
hilo desactivado, inicio
Traceback (most recent call last):
  File "__init__.py", line 38, in <module>
    oa=MainWindow()
  File "__init__.py", line 21, in __init__
    self.crearHilo()
  File "__init__.py", line 29, in crearHilo
    self.t.start()
  File "/usr/lib/python2.6/threading.py", line 467, in start
    raise RuntimeError("thread already started")
RuntimeError: thread already started

alguno sabe por que?
desde ya muchas gracias

[razpeitia]

Esto no se debe al soporte de hilos en python, esto se debe a que solo tienes un hilo nunca creaste otro hilo. Solo tienes el hilo principal y el hilo t.

Te dejo un ejemplo sencillo de como manejar hilos (ademas de una comparación):

Sin Hilos

Código Python:

import time
 
def f(num):
    time.sleep(1)
    print "Hilo %d" % num
    
for i in range(10):
    f(i)
 

Con Hilos

Código Python:

import sys
import threading, time
 
class Thread(threading.Thread):
    def __init__(self, num):
        threading.Thread.__init__(self)
        self.num = num
 
    def run(self):
        time.sleep(1)
        sys.stdout.write("Hilo %d\n" % self.num)
 
for i in range(10):
    t = Thread(i)
    t.start()
 

[theteam]

vos decis que no se puede iniciar y parar un hilo cuantas veces quiera por mas que siempre mantenga solo una iniciacion del hilo a la vez? (fijate que yo paro el hilo y cuando el hilo ya finalizo lo vuelvo a iniciar)
en caso de que lo anterior sea afirmativo, crear varios hilos para esto, no seria ineficiente? o cuando termina un hilo no queda en memoria?

probe este codigo y anda, pero me gustaria que no queden hilos colgados en memoria:
(lo que hago es antes de hacer hilo.start(), hago: hilo=threading.Thread(target=self.hilo)

Código Python:

class MainWindow():
    
    def __init__(self):
        # t es un hilo
        self.t = threading.Thread(target=self.hilo)
        #como python no brinda una forma de parar ciclos desde afuera necesitamos una variable :S, pero bueh
        self.parar=True
        print "creo hilo por primera vez"
        self.crearHilo()
        print "creo un hilo sin parar el anterior"
        self.crearHilo()
        print "paro el hilo, espero 5 seg y vuelvo a crear"
        self.parar=True
        time.sleep(10)
        self.crearHilo()
    
    def crearHilo(self):
        if self.t.isAlive():
            print "hilo activo, no inicio"
        else:
            self.parar=False
            print "hilo desactivado, inicio"
            # t es un hilo
            self.t = threading.Thread(target=self.hilo)
            self.t.start()
    
    def hilo(self):
        while (not self.parar):
            print "se esta ejecutando el hilo"
            time.sleep(2)
        print "se esta acabando el hilo"
        return
 
if __name__ == "__main__":
    oa=MainWindow()
 

en cuanto a la forma de implementar hilos, tanto heredando de threads (como me propusiste vos) como haciendo como hago yo, tengo entendido que es lo mismo, o por lo menos es valido hacerlo de las dos formas.
se que para el ejemplo que puse es trivial los hilos, pero lo simplifique para no enredarme con otras cosas y centrarme en el problema de los hilos y para que ustedes entiendan el codigo sin tener que leer mucho codigo.

gracias por responder!!

[razpeitia]

Simplificando tu problema, sin utilizacion de clases para que sea realmente facil de leer

Código Python:

import threading
from time import sleep
 
stop = True #Variable de control
 
def run(): #Esto es lo que hace el hilo
    global stop
    while not stop:
        print "Hilo en ejecucion por 2s"
        sleep(2)
 
def execThread(thread):
    global stop
    if thread.isAlive():
        print "Hilo Ejecutandose"
    else:
        stop = False
        print "Hilo antes o despues de ejecutarse"
        thread.start()
        
t = threading.Thread(target=run) #Aqui creas un hilo
execThread(t)
execThread(t)
stop = True
sleep(5)
execThread(t)
 

Ademas citando a la documentación:

Iniciado por pydoc

This method will raise a RuntimeException if called more than once on the same thread object.

Iniciado por pydoc-es

Este metodo lanzara la excepcion RuntimeError si es llamada mas de una vez en el mismo objeto thread.

En pocas palabras, un thread(hilo) una ejecución.

[theteam]

eso quedo mucho mas prolijo, gracias :)

pero si lo ejecutas tira el error que comentaba en el principio, para solucionarlo quedaria asi:

Código Python:

import threading
from time import sleep
 
stop = True #Variable de control
 
def run(): #Esto es lo que hace el hilo
    global stop
    while not stop:
        print "Hilo en ejecucion por 2s"
        sleep(2)
 
def execThread(thread):
    global stop
    if thread.isAlive():
        print "Hilo Ejecutandose"
    else:
        stop = False
        print "Hilo antes o despues de ejecutarse"
        t = threading.Thread(target=run) #(ESTO ES LO QUE FALTO AGREGAR)
        thread.start()
        
t = threading.Thread(target=run) #Aqui creas un hilo
execThread(t)
execThread(t)
stop = True
sleep(5)
execThread(t)
 

gracias por tomarte el trabajo de codificar para un desconocido!
ahora la unica duda que me queda es:
cuando un hilo termina de ejecutarse, queda algun residuo de el en memoria?? porque si es asi, y estamos en la necesidad de correr muchos hilos (porque no podemos iniciar y cortar, iniciar y cortar uno mismo) la cosa se pone mas ineficiente. o estoy tirando cualquier pavada?

[razpeitia]

Para que quieres detener la ejecución de un hilo?

Si necesitas que termine un hilo, antes de que empiecen una serie de hilos puedes sincronizarlos.

Con respecto a lo de la memoria de eso se encarga el gc (Garbage Collector) o recolector de basura así que no tienes que preocuparte por eso.

Pondré algunos ejemplos:

Código Python:

...
#Aqui x nunca es accesado, por lo tanto ese espacio que ocupa en memoria puede
#ser reciclado
x = 12
if y:
    do_something()
else:
    do_something_else()
...
 
...
#Aqui x solo es accesado una vez, puede ser candidato a ser reciclado una vez
#ejecutado
x = 12
if (x % y) == 0:
    print "Multiplo"
else:
    print "No multiplo"
...
 
...
#Aqui el objeto Foo nunca es acesado, se dice que es basura sintactica
x = Foo()
y = Bar()
x = Qwerty()
...
 
...
x = 12
if (x % y) == 0:
    print "Multiplo"
else:
    print "No multiplo"
del x #Aqui liberas el espacio que ocupa x manualmente.
...
 

[theteam]

la idea de iniciar y pausar un hilo varias veces es la siguiente:
yo tengo un hilo principal que maneja una interfaz grafica. En esta hay varios paneles a los cuales se acceden apretando los botones "siguiente" y "anterior" de los paneles (tipico instalador de programas)
el tema es que en uno de los paneles necesito ver si hay algunos dispositivos (como pendrives, cds, dvds, etc) conectados, por lo que necesito un segundo hilo que cada cierto tiempo actualice los dispositivos.
el problema es que el usuario puede ir para atras y volver, con lo cual mataria el hilo y lo volveria a empezar y es aqui donde tuve que postear mi problema ;) que ahora ya esta resuelto.

en cuanto al manejo de memoria tenes razon, al crear otro objeto "hilo" el anterior queda sin referencia, por lo cual es candidato para que se lo lleve el garbage.
muchas gracias por todas las explicaciones razpeitia, me quedo todo muy claro :D
saludos!

[llos]

Yo tengo la misma duda, basicamente si haces un porgrama con interfaz grafica, o sin... pero en mi caso tambien es con interfaz grafica y por lo que sea hay una opcion empezar, que se hace con un thread, para liberar al programa principal, y por lo que sea tienes una opcion parar, como se puede hacer para matar el hilo...

[razpeitia]

Lo ideal es terminar cada hilo apropiadamente, esto se puede hacer checado en intervalos regulares el flag "exit" o "salida". Si el flag es verdadero para algún hilo entonces que termine su ejecución apropiadamente.

Para mas información aquí.

[DeMoivre]

El asunto es si el hilo queda trabado en alguna función como raw_input() o socket.recv(),

¿Cómo se podría hacer para matarlos a los threading.Thread's?

[razpeitia]

A que le llamas "trabado"?

Para los sockets para eso hay un timeout (para que no queden esperando infinitamente) y para raw_input no se me ocurre como se puede quedar "trabado" ya que lanza excepciones cuando algo sale mal.

[AlvaroG]

Python no provee funcionalidad para matar un hilo a voluntad. El hilo debe terminar su método run. Esto es porque cada hilo debe ser capaz de liberar los recursos que tenga y terminar lo que tenga pendiente antes de finalizar.

Si un hilo se te queda colgado esperando algo que nunca llegará, lo que deberías hacer no es intentar matarlo sino reacomodar la tarea que debe hacer, de modo que no se quede colgado.


saludos.

[DeMoivre]

Iniciado por AlvaroG

Python no provee funcionalidad para matar un hilo a voluntad. El hilo debe terminar su método run. Esto es porque cada hilo debe ser capaz de liberar los recursos que tenga y terminar lo que tenga pendiente antes de finalizar.

Si un hilo se te queda colgado esperando algo que nunca llegará, lo que deberías hacer no es intentar matarlo sino reacomodar la tarea que debe hacer, de modo que no se quede colgado.


saludos.

ok, GRACIAS

Justo había encontrado un artículo que decía que no intentara matar un hilo colgado por un socket bloqueante porque fastidiaría todo.

Iniciado por razpeitia

A que le llamas "trabado"?

Para los sockets para eso hay un timeout (para que no queden esperando infinitamente) y para raw_input no se me ocurre como se puede quedar "trabado" ya que lanza excepciones cuando algo sale mal.

El hilo se quedaría TRABADO/COLGADO esperando que alguien introduzca algo. Porque, según leí, la aplicación termina cuando el hilo principal y todos los demás hilos se hayan muerto (esto es usando theading).

Si yo metiera un RAW_INPUT en un hilo para que mientras se espera la entrada de datos por teclado se hagan otras cosas, al finalizar el hilo principal me quedaría COLGADO el hilo del RAW_INPUT. Se que con un EXIT(0) lo podría matar, pero mataría todos los hilos a la vez y lo que me intereza es matar solo el del RAW_INPUT.

(Esto es un ejemplo hipotético), igualmente ya me quedó claro que no se pueden matar threading.Threads. Lo pongo por eso de que no se te ocurría como se podían quedar trabados con un raw_input.


Saludos