Hilos en espiral ... ¿cómo usarlos correctamente?

Question

Tengo que escribir una aplicación sencilla que se ejecuta dos hilos: - Hilo de 1: se ejecuta a intervalos cronometrados, digamos cada 1 minuto - rosca 2: sólo un 'normal' while True bucle que hace 'cosas'

si no el requisito de circular a intervalo de tiempo no habría mirado trenzado en absoluto, pero el sueño sencillo (60) no es lo suficientemente bueno y construcción como:

l = task.LoopingCall(timed_thread) 
l.start(60.0) 
reactor.run() 

se veía muy fácil de lograr lo que quería allí .

Ahora, ¿cómo 'adecuadamente' agrego otro hilo?

veo dos opciones aquí:

• uso de la biblioteca roscado y ejecutar uno de dos hilos '' pitón ejecutar mi bucle while, y otro reactor.run correr(). Pero Google parece oponerse a este enfoque y sugiere el uso de roscado trenzado
• Utilice roscado trenzado. Eso es lo que he intentado, pero de alguna manera esto me parece un poco torpe.

Esto es lo que ocurrió:

def timed_thread(): 
    print 'i will be called every 1 minute' 
    return 

def normal_thread(): 
    print 'this is a normal thread' 
    time.sleep(30) 
    return 

l = task.LoopingCall(timed_thread) 
l.start(60.0) 
reactor.callInThread(normal_thread) 
reactor.run() 

que parece funcionar, pero! No puedo detener la aplicación Si presiono^C no haría nada (sin 'callInThread' simplemente se detiene como lo esperaría).^Z bombardea a shell, y si hago 'kill% 1' parece matar el proceso (el shell lo informa), pero el hilo 'normal' sigue en ejecución. kill PID no se desharía de él, y la única cura es kill -9. Muy extraño.

So. ¿Qué estoy haciendo mal? ¿Es un enfoque correcto implementar dos hilos en twisted? ¿No debería molestarme con retorcer? ¿Qué otras alternativas 'estándares' son para implementar llamadas temporizadas? ('Estándar' quiero decir que puedo instalar easy_ o instalarlos, no quiero comenzar a descargar y usar algunos scripts aleatorios de páginas web aleatorias).

Answer 1

Suponiendo que el principal es relativamente no-bloqueo:

import random 
from twisted.internet import task 

class MyProcess: 
    def __init__(self): 
    self.stats = [] 
    self.lp = None 
    def myloopingCall(self): 
    print "I have %s stats" % len(self.stats) 
    def myMainFunction(self,reactor): 
    self.stats.append(random.random()) 
    reactor.callLater(0,self.myMainFunction,reactor) 
    def start(self,reactor): 
    self.lp = task.LoopingCall(self.myloopingCall) 
    self.lp.start(2) 
    reactor.callLater(0,self.myMainFunction,reactor) 
    def stop(self): 
    if self.lp is not None: 
     self.lp.stop() 
    print "I'm done" 

if __name__ == '__main__': 
    myproc = MyProcess() 
    from twisted.internet import reactor 
    reactor.callWhenRunning(myproc.start,reactor) 
    reactor.addSystemEventTrigger('during','shutdown',myproc.stop) 
    reactor.callLater(10,reactor.stop) 
    reactor.run() 

 
$ python bleh.py 
I have 0 stats 
I have 33375 stats 
I have 66786 stats 
I have 100254 stats 
I have 133625 stats 
I'm done 

Answer 2

Usted no explicó por qué en realidad se necesita hilos aquí. Si lo hubiera hecho, podría haber sido capaz de explicar por qué no lo necesita. ;)

Dejando eso de lado, puedo confirmar que su comprensión básica de las cosas es correcta. Sin embargo, un posible malentendido que puedo aclarar es la noción de que "hilos de pitón" y "hilos trenzados" son diferentes entre sí. Ellos no están. Python proporciona una biblioteca de subprocesos. Todas las API de subprocesos de Twisted se implementan en términos de la biblioteca de subprocesos de Python. Solo la API es diferente.

En cuanto al apagado, tiene dos opciones.

• Comience su secuencia de ejecución para siempre utilizando las API de subprocesamiento de Python directamente y convierta el subproceso en un demonio. Su proceso puede salir incluso mientras los hilos daemon aún se estén ejecutando. Un posible problema con esta solución es que algunas versiones de Python tienen problemas con hilos daemon que provocarán un bloqueo en el momento del cierre.
• Crea tu hilo usando las API de Twisted o las API stdlib threading pero también agrega un enlace de cierre trenzado usando reactor.addSystemEventTrigger('before', 'shutdown', f). En ese gancho, comuníquese con el hilo de trabajo y dígale que se apague. Por ejemplo, puede compartir un threading.Event entre el subproceso Twisted y su subproceso y tiene el enganche set. El hilo de trabajo puede verificar periódicamente si se ha configurado y salir cuando se da cuenta de que lo ha sido. Además de no fallar, esto le da otra ventaja sobre los hilos daemon: le permitirá ejecutar algún código de limpieza o finalización en su hilo de trabajo antes de que el proceso finalice.