Resultados de la búsqueda a petición "multiprocessing"
Trabajo de multiprocesamiento de Python a tarea de apio pero AttributeError
Hice una función multiprocesada como esta, import multiprocessing import pandas as pd import numpy as np def _apply_df(args): df, func, kwargs = args return df.apply(func, **kwargs) def apply_by_multiprocessing(df, func, **kwargs): workers = ...
¿Cuál es la ventaja de las colas sobre las tuberías cuando se comunican entre procesos?
¿Cuáles serían las ventajas (si las hubiera) de usar 2Colas [http://docs.python.org/library/multiprocessing.html#multiprocessing.Queue]sobre unTubo [http://docs.python.org/library/multiprocessing.html#multiprocessing.Pipe]para comunicarse entre ...
Proceso de multiprocesamiento de Python vs. Python VM independiente
Aparte de la facilidad de uso demultiprocessing módulo cuando se trata de conectar procesos con recursos de comunicación, ¿hay alguna otra diferencia entre generar múltiples procesos usandomultiprocessing en comparación con el usosubprocess ...
Multiprocesamiento de Python: RuntimeError: "Los objetos de cola solo deben compartirse entre procesos a través de la herencia"
Soy consciente del multiprocesamiento.Manager () y de cómo se puede usar para crear objetos compartidos. En particular, colas que se pueden compartir entre los trabajadores. Hay ...
Cómo combinar multiprocesamiento y eventlet
Tengo una tarea que necesita iniciar 2 procesos y dentro de cada proceso necesito iniciar 2 hilos para que realmente funcione. A continuación se muestra el código fuente que utilicé para simular mi caso de uso. import multiprocessing import ...
Importar scipy rompe el soporte de multiprocesamiento en Python
Me encuentro con un problema extraño que no puedo explicar. ¡Espero que alguien pueda ayudar por favor! Estoy ejecutando Python 2.7.3 y Scipy v0.14.0 y estoy tratando de implementar algunos algoritmos multiprocesador muy simples para acelerar mi ...
Multiprocesamiento de lista compartida
He escrito un programa como este: from multiprocessing import Process, Manager def worker(i): x[i].append(i) if __name__ == '__main__': manager = Manager() x = manager.list() for i in range(5): x.append([]) p = [] for i in range(5): ...
¿Por qué la operación get () en multiprocesamiento.Pool.map_async tarda tanto?
import multiprocessing as mp import numpy as np pool = mp.Pool( processes = 4 ) inp = np.linspace( 0.01, 1.99, 100 ) result = pool.map_async( func, inp ) #Line1 ( func is some Python function which acts on input ) output = ...
¿Cómo multiprocesar, multiprocesar un archivo grande dividiéndolo en pequeños trozos basados en los valores de una columna en particular?
He escrito un programa de Python para un proceso ...
Multiprocesamiento con cola compartida y criterios de finalización
Tengo esta función original que quiero cambiar a multiproceso: def optimal(t0, tf, frequences, delay, ratio = 0): First = True # First for s in delay: delay = 0 # delay between signals, timelines = list() for i in range(len(frequences)): ...