Resultados de la búsqueda a petición "multiprocessing"
Compartir muchas colas entre procesos en Python
Estoy consciente demultiprocessing.Manager() y cómo se puede usar para crear objetos compartidos, en particular colas que se pueden compartir entre los trabajadores. Ahi estaesta ...
El multiprocesamiento funciona en Ubuntu, no en Windows
Estoy tratando de usareste ejemplo [http://www.defuze.org/archives/198-managing-your-process-with-the-cherrypy-bus.html] como plantilla para un sistema de colas en mi aplicación cherrypy. Pude convertirlo de python 2 a python 3 (cambiarfrom ...
CPU de alto kernel cuando se ejecutan múltiples programas de Python
Desarrollé un programa de Python que realiza cálculos numéricos pesados. Lo ejecuto en una máquina Linux con 32 CPU Xeon, 64 GB de RAM y Ubuntu 14.04 de 64 bits. Lanzo varias instancias de Python con diferentes parámetros de modelo en paralelo ...
Estado compartido en procesos de multiprocesamiento
Por favor considere este código: import time from multiprocessing import Process class Host(object): def __init__(self): self.id = None def callback(self): print "self.id = %s" % self.id def bind(self, event_source): event_source.callback = ...
Comenzando un proceso separado
Quiero que un script inicie un nuevo proceso, de modo que el nuevo proceso continúe ejecutándose después de que finalice el script inicial. Esperaba que pudiera usarmultiprocessing.Process para comenzar un nuevo proceso y establecerdaemon=True ...
Multiprocesamiento vs Threading Python
Estoy tratando de entender las ventajas demultiprocesamiento [http://docs.python.org/library/multiprocessing]terminadoenhebrar [http://docs.python.org/library/threading]. Yo sé esomultiprocesamientoevita el bloqueo global del intérprete, pero ...
Multiprocesamiento de Python que conduce a muchos procesos zombies
He estado implementando la biblioteca de multiprocesamiento de Python utilizando un grupo de trabajadores. Implementé el siguiente código import main1 t1 = time.time() p = Pool(cores) result = p.map(main1, client_list[client]) if result == []: ...
¿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) ese cambio en cada iteración del ciclo for. Quiero paralelizar esta operación ya que un conjunto de argumentos hace que la ...
Python Chunking CSV File Multiproccessing
Estoy usando el siguiente código para dividir un archivo CSV en varios fragmentos (procedentes deaquí [https://stackoverflow.com/questions/8717179/chunking-data-from-a-large-file-for-multiprocessing] ) def worker(chunk): print len(chunk) def ...
cola de multiprocesamiento llena
Estoy usando concurrent.futures para implementar multiprocesamiento. Recibo una cola. Error completo, lo cual es extraño porque solo estoy asignando 10 trabajos. A_list = [np.random.rand(2000, 2000) for i in range(10)] with ProcessPoolExecutor() ...