Me gustaría crear un subproceso o un proceso que se ejecute para siempre en un bucle While True. Necesito enviar y recibir datos al trabajador en forma de colas, ya sea un multiprocessing.Queue () o collections.deque (). Prefiero usar collections.deque () ya que es significativamente más rápido. También necesito poder matar al trabajador con el […]
Tengo un poco de código Python multiprocessing que se ve un poco así: import time from multiprocessing import Pool import numpy as np class MyClass(object): def __init__(self): self.myAttribute = np.zeros(100000000) # basically a big memory struct def my_multithreaded_analysis(self): arg_lists = [(self, i) for i in range(10)] pool = Pool(processes=10) result = pool.map(call_method, arg_lists) print result […]
Siguiendo el código no se ejecuta como se esperaba. import multiprocessing lock = multiprocessing.Lock() def dummy(): def log_results_l1(results): lock.acquire() print(“Writing results”, results) lock.release() def mp_execute_instance_l1(cmd): print(cmd) return cmd cmds = [x for x in range(10)] pool = multiprocessing.Pool(processes=8) for c in cmds: pool.apply_async(mp_execute_instance_l1, args=(c, ), callback=log_results_l1) pool.close() pool.join() print(“done”) dummy() Pero funciona si las funciones […]
Estoy tratando de dividir por bucle, es decir N = 1000000 for i in xrange(N): #do something utilizando multiprocesamiento. El proceso funciona bien con valores pequeños de N. El problema surge cuando uso valores mayores de N. Algo extraño sucede antes o durante el proceso de p.join () y el progtwig no responde. Si pongo […]
Estaba aprendiendo sobre multiprocesamiento y multiproceso. Por lo que entiendo, los subprocesos se ejecutan en el mismo núcleo, por lo que me preguntaba si crearé múltiples procesos dentro de un subproceso secundario. ¿Estarán limitados a ese único núcleo también? Estoy usando python, así que esta es una pregunta sobre ese idioma específico, pero me gustaría […]
El multiprocesamiento es una herramienta poderosa en Python, y quiero entenderlo más a fondo. Quiero saber cuándo usar los lockings y colas regulares y cuándo usar un administrador de multiprocesamiento para compartirlos entre todos los procesos. Se me ocurrieron los siguientes escenarios de prueba con cuatro condiciones diferentes para multiprocesamiento: Usando un pool y NO […]
Estoy usando el servidor de Python sin locking de E / S Tornado. Tengo una clase de solicitudes GET que pueden tardar una cantidad de tiempo significativa en completarse (piense en el rango de 5 a 10 segundos). El problema es que el Tornado bloquea estas solicitudes para que las solicitudes rápidas posteriores se retengan […]
Estoy trabajando en el proyecto llamado “Detección de unidades de acciones faciel” Estoy usando python2.7 y opencv 2.4 El error: pickle.PicklingError: Can’t pickle : it’s not the same object as cv2.Boost Un rastreo parcial, transcrito de una captura de pantalla : Loading classifier for action unit 27 Traceback (most recent call last): File “C:\Python27\audetect-master\audetect-interactive.py”, line […]
Estoy tratando de usar este ejemplo como plantilla para un sistema de colas en mi aplicación cherrypy. Pude convertirlo de Python 2 a Python 3 (cambiar from Queue import Empty a from queue import Empty ) y ejecutarlo en Ubuntu. Pero cuando lo ejecuto en Windows me sale el siguiente error: F:\workspace\test>python test.py Traceback (most […]
Descripción del Proyecto: Conecte el progtwig “C” existente (control principal) a la GUI / Widget de Python. Para esto estoy usando un FIFO. El progtwig C está diseñado para mirar telemetría basada en cuadros. La GUI de Python realiza dos funciones: Ejecuta / crea gráficos (probablemente creados a través de matplotlib) a través del widget […]