Articles of multiproceso

Multiprocesamiento en python con más de 2 niveles.

Quiero hacer un progtwig y quiero hacer un engendro como este proceso -> n proceso -> n proceso ¿Puede el proceso de generación de segundo nivel con multiprocesamiento? Usando el módulo multiprocessinf de python 2.6 thnx

Leyendo múltiples archivos usando thread / multiprocess

Actualmente estoy extrayendo archivos .txt de la lista de rutas de FileNameList, que está funcionando. Pero mi principal problema es que es demasiado lento cuando los archivos son demasiados. Estoy usando este código para imprimir la lista de archivos txt, import os import sys #FileNameList is my set of files from my path for filefolder […]

Actualización de PySide y QProgressBar en un hilo diferente

Esto puede ser un post largo, así que, gracias de antemano por estar conmigo hasta el final. Aquí está el problema, (creo que es bastante básico, solo mi inexperiencia con PiSide y Qt lo hace más difícil para mí). Tengo una ventana principal con un elemento de menú, supongo “Proceso”. el código está siguiendo from […]

multiproceso.valor borrar la syntax?

Quiero usar multiprocesamiento. Valorar el uso de una variable en varios procesos, pero la syntax no está clara en la documentación de Python. ¿Puede alguien decirme qué debo usar como tipo (mi variable es una letra) y dónde colocar el nombre de mi variable? EDITAR Intenté usar el Administrador para compartir mi carta entre procesos. […]

Python Singleton en multiprocesamiento

¿Cómo puedo codificar para compartir la misma instancia de una clase “singletonic” entre los procesos?

¿Por qué `print` no funciona en python multiprocessing pool.map

Estoy tratando de implementar el módulo de multiprocessing para trabajar con un archivo csv grande. Estoy usando Python 2.7 y siguiendo el ejemplo de aquí . Ejecuté el código no modificado (copiado a continuación para mayor comodidad) y noté que print declaraciones de print dentro de la función de trabajo no funcionan. La imposibilidad de […]

¿Por qué un proceso de daemon multiproceso de Python no se imprime en una salida estándar?

He estado experimentando con multiprocesamiento y encontrándome con un locking mental con demonios. Tengo un proceso de daemon y otro que no lo es. El daemon emite una salida cada segundo indefinidamente, mientras que el no daemon imprime la salida inmediatamente después del inicio, duerme durante 3 segundos, luego vuelve a imprimir y vuelve. El […]

Multiprocesamiento Python para operaciones costosas con matriz 2D

Tengo una función, digamos fun(a,b) que es bastante cara y devuelve un conjunto de datos. Mi método actual se ve así: a = np.linspace(0,100,300) b = np.linspace(0,100,300) A,B = np.meshgrid(a,b) Y = np.zeros(A.shape) for i,av in enumerate(a): for j, bv in enumerate(b): Y[i,j] = fun(av,bv) (Algo así, tuve que confundir un poco las cosas para […]

Python ¿Cómo hacer multiprocesamiento dentro de una clase?

Tengo una estructura de código que se parece a esto: Class A: def __init__(self): processes = [] for i in range(1000): p = Process(target=self.RunProcess, args=i) processes.append[p] # Start all processes [x.start() for x in processes] def RunProcess(self, i): do something with i… Guión principal: myA = A() Parece que no puedo conseguir esto para correr. […]

¿Cómo puedo restringir el scope de un proceso de multiprocesamiento?

Usando el módulo de multiprocessing de python, el siguiente ejemplo creado se ejecuta con requisitos de memoria mínimos: import multiprocessing # completely_unrelated_array = range(2**25) def foo(x): for x in xrange(2**28):pass print x**2 P = multiprocessing.Pool() for x in range(8): multiprocessing.Process(target=foo, args=(x,)).start() ¡Descomente la creación de la matriz completely_unrelated_array y encontrará que cada proceso generado asigna […]