Resultados de la búsqueda a petición "multiprocessing"
multiprocessing pool example no funciona y congela el kernel
Estoy tratando de paralelizar una secuencia de comandos, pero por una razón desconocida el núcleo simplemente se congela sin que se produzcan errores. ejemplo de trabajo mínimo: from multiprocessing import Pool def f(x): return x*x p = ...
¿Cómo usar el método multiprocesamiento.Queue.get?
El siguiente código coloca tres números en una cola. Luego intenta recuperar los números de la cola. Pero nunca lo hace. ¿Cómo obtener los datos de la cola? import multiprocessing queue = multiprocessing.Queue() for i in range(3): queue.put(i) ...
¿Cómo lograr el paralelismo de la GPU usando el flujo de tensor?
Estoy escribiendo unagpu programa de coincidencia de cadenas basado en tensorflow editar distancia caracteristicas. Al conocer la parte correspondiente, extraeré los detalles y luego los guardaré en una tabla de datos que finalmente se guardará ...
Python multiprocessing pool.map para múltiples argumentos
En la biblioteca de multiprocesamiento de Python, ¿hay una variante de pool.map que admita múltiples argumentos? text = "test" def harvester(text, case): X = case[0] text+ str(X) if __name__ == '__main__': pool = ...
Se copian datos de solo lectura copiados a diferentes procesos para multiprocesamiento?
El fragmento de código que tengo se ve más o menos así: glbl_array = # a 3 Gb array def my_func( args, def_param = glbl_array): #do stuff on args and def_param if __name__ == '__main__': pool = Pool(processes=4) pool.map(my_func, range(1000)) ...
Problema de multiprocesamiento de Python / malentendido
Tengo un problema con el multiprocesamiento; Estoy usando python2.7 en Linux 2.6.36. Sé que esto sería mucho más fácil con un módulo o biblioteca de nivel superior, pero estoy tratando de usar las funciones de nivel inferior (os.fork () y ...
ultiprocesamiento @Python: sincronización de un objeto similar a un archivo
Estoy tratando de crear un archivo como objeto destinado a ser asignado a sys.stdout / sys.stderr durante las pruebas para proporcionar resultados deterministas. No está destinado a ser rápido, solo confiable. Lo que tengo hasta ahoracas ...
¿Cómo capturar la salida de un script de shell que se ejecuta en un proceso separado, en un wxPython TextCtrl?
Un script de shell de larga ejecución produce stdout y stderr, que me gustaría mostrar en un textctrl en una GUI. Esto es posible mediante el enhebrado y la separación del hilo GUI del hilo del script de shell. Sin embargo, cuando implemento ...
El límite máximo de tamaño de cola de multiprocesamiento es 32767
Estoy tratando de escribir un programa Python 2.6 (OSX) usando multiprocesamiento, y quiero llenar una cola con más de 32767 elementos predeterminados. from multiprocessing import Queue Queue(2**15) # raises OSErrorQueue(32767) funciona bien, ...
python argumentos de multiprocesamiento: copia profunda?
from multiprocessing import Process # c is a container p = Process(target = f, args = (c,)) p.start() Supongo una copia profunda dec se pasa a la funciónf porque una copia superficial no haría ningún s, ense en el caso de un nuevo proceso (el ...