Articles of multiproceso de

Técnicas de depuración multiprocesamiento.

Estoy teniendo problemas para depurar una aplicación de proceso múltiple (específicamente utilizando un grupo de procesos en el módulo de multiprocesamiento de python). Tengo un punto muerto aparente y no sé qué lo está causando. El seguimiento de la stack no es suficiente para describir el problema, ya que solo muestra el código en el […]

multiprocessing.pool.map y función con dos argumentos

Estoy usando multiprocessing.Pool() Esto es lo que quiero hacer: def insert_and_process(file_to_process,db): db = DAL(“path_to_mysql” + db) #Table Definations db.table.insert(**parse_file(file_to_process)) return True if __name__==”__main__”: file_list=os.listdir(“.”) P = Pool(processes=4) P.map(insert_and_process,file_list,db) # here having problem. Quiero pasar 2 argumentos. Lo que quiero hacer es inicializar solo 4 conexiones de base de datos (aquí intentará crear una conexión en […]

Impresión dinámica de actualización de multiprocesamiento o multiproceso en Python

He implementado un descargador multiprocesamiento. ¿Cómo puedo imprimir la barra de estado (tasa completa, velocidad de descarga) que se puede actualizar automáticamente en diferentes partes del terminal? Me gusta esto: 499712 [6.79%] 68k/s // keep refreshing 122712 [16.79%] 42k/s // different process/thread 99712 [56.32%] 10k/s código: download(…) … f = open(tmp_file_path, ‘wb’) print “Downloading: %s […]

Realizar un bucle for en paralelo en Python 3.2

Posible duplicado: ¿Cómo paralelizo un simple bucle de python? Soy bastante nuevo en Python (usando Python 3.2) y tengo una pregunta relacionada con la paralelización. Tengo un bucle for que deseo ejecutar en paralelo usando “multiprocesamiento” en Python 3.2: def computation: global output for x in range(i,j): localResult = … #perform some computation as a […]

Ejecutar métodos de clase en hilos (python)

Actualmente estoy aprendiendo Python and Classes y tengo una pregunta básica, pero no encontré ninguna respuesta. Digamos que tengo esta clase ficticia class DomainOperations: def __init__(self, domain): self.domain = domain self.domain_ip = ” self.website_thumbnail = ” def resolve_domain(self): #resolve domain to ipv4 and save to self.domain_ip def generate_website_thumbnail(self): #generate website thumbnail and save the url […]

¿Cómo usar el multiprocesamiento para paralelizar dos llamadas a la misma función, con diferentes argumentos, en un bucle for?

En un bucle for, estoy llamando a una función dos veces pero con diferentes conjuntos de argumentos ( argSet1 , argSet2 ) que cambian en cada iteración del bucle for . Quiero paralelizar esta operación ya que un conjunto de argumentos hace que la función llamada se ejecute más rápido, y el otro conjunto de […]

Python Tkinter Label redibujando cada 10 segundos

Tengo este siguiente código de Python Tkinter que vuelve a dibujar la etiqueta cada 10 segundos. Mi pregunta es, para mí, parece que está dibujando la nueva etiqueta una y otra vez sobre la etiqueta antigua. Entonces, eventualmente, después de unas horas habrá cientos de dibujos superpuestos (al menos por lo que entiendo). ¿Usará esto […]

Multiproceso Python con una sola función.

Tengo una simulación que se está ejecutando actualmente, pero la ETA es de aproximadamente 40 horas. Intento acelerarlo con el multiprocesamiento. Esencialmente itera más de 3 valores de una variable (L), y más de 99 valores de una segunda variable (a). Usando estos valores, esencialmente ejecuta una simulación compleja y devuelve 9 desviaciones estándar diferentes. […]

El multiprocesamiento de Python genera continuamente procesos de pythonw.exe sin realizar ningún trabajo real

No entiendo por qué este simple código # file: mp.py from multiprocessing import Process import sys def func(x): print ‘works ‘, x + 2 sys.stdout.flush() p = Process(target= func, args= (2, )) p.start() p.join() p.terminate() print ‘done’ sys.stdout.flush() crea “pythonw.exe” procesa continuamente y no imprime nada, aunque lo ejecuto desde la línea de comandos: python […]

Hacer un temporizador de Python interuptable de “cualquier clave”

Estoy tratando de hacer un temporizador simple que cuente hasta que sea interrumpido por la entrada del teclado. En este momento estoy usando CTRL + C para detener el temporizador, pero me gustaría hacer algo más simple como pulsar el espacio o ingresar o “cualquier tecla”. Escuché que esto se puede hacer con el módulo […]