Tengo dos subprocesos y quiero que un subproceso se ejecute durante 10 segundos, y luego paro este subproceso, mientras que otro subproceso se ejecuta y luego el primer subproceso comienza de nuevo; este proceso se repite Así por ejemplo from threading import Thread import sys import time class Worker(Thread): Listened = False; def __init__(self): while […]
Soy nuevo en el procesamiento de subprocesos múltiples, así que perdónenme si escribo los términos o me olvido de algo obvio. El código a continuación no ofrece ninguna ventaja de tiempo sobre el código diferente que llama a las mismas dos funciones una tras otra. import time import threading start_time = time.clock() def fibonacci(nth): #can […]
Comienzo un hilo usando el siguiente código. t = thread.start_new_thread(myfunction) ¿Cómo puedo matar el hilo t de otro hilo. Básicamente hablando en términos de código, quiero poder hacer algo como esto. t.kill() Tenga en cuenta que estoy usando Python 2.4.
Digamos que tengo una función que escribe en un archivo. También tengo una función que repite repetidamente la lectura de dicho archivo. Tengo ambas de estas funciones que se ejecutan en hilos separados. (De hecho, estoy leyendo / escribiendo en registros a través de MDIO, por lo que no puedo ejecutar ambos subprocesos simultáneamente, solo […]
Soy nuevo en Python y estoy avanzando con el threading : estoy haciendo una conversión de archivos de música y quiero poder utilizar los múltiples núcleos de mi máquina (un hilo de conversión activo por núcleo). class EncodeThread(threading.Thread): # this is hacked together a bit, but should give you an idea def run(self): decode = […]
en Python, si quiero mantener un proceso o un hilo en ejecución para siempre , normalmente puedo hacer esto con un bucle while vacío: while 1: pass esto, sin embargo, consumirá una cantidad injusta de proceso de CPU. Añadir un sueño corto funcionaría import time while 1: time.sleep(0.01) ¿Hay alguna manera mejor y más limpia […]
Estoy escribiendo un script que tiene 5 hilos, quiero compartir / redirigir la salida estándar de todo el hilo, para obtener todas las impresiones correctamente. He intentado con el siguiente código pero no funciona, ¿alguien puede ayudarme? class Logwriter(): def __init__(self): self.terminal = sys.stdout def write(self,message): lock = threading.Lock() lock.acquire() self.terminal.write(message) lock.release() sys.stdout=Logwriter()
Tengo un código: for url in get_lines(file): visit(url, timeout=timeout) Obtiene las URL del archivo y lo visita (por urllib2 ) en for loop. ¿Es posible hacer esto en pocos hilos? Por ejemplo, 10 visitas al mismo tiempo. He intentado: for url in get_lines(file): Thread(target=visit, args=(url,), kwargs={“timeout”: timeout}).start() Pero no funciona, sin efecto, las URL se […]
Tengo una aplicación de subprocesos múltiples escrita en Python en la que un subproceso “se encarga” de la GUI, y el otro es el subproceso de trabajo. Sin embargo, el subproceso de trabajo tiene dos funciones principales (más o menos dos trabajos principales), y debo decirle a la función de ejecución qué trabajo debe hacer […]
Estoy creando una secuencia de comandos de python que acepta una ruta a un archivo remoto y un número de subprocesos. El tamaño del archivo se dividirá por la cantidad de subprocesos, cuando cada subproceso se complete, quiero que adjunten los datos de recuperación a un archivo local. ¿Cómo lo administro de modo que el […]