Resultados de la búsqueda a petición "multiprocessing"
gensim LdaMulticore no multiprocesamiento?
Cuando corro gensimLdaMulticore modelo en una máquina con 12 núcleos, utilizando: lda = LdaMulticore(corpus, num_topics=64, workers=10)Recibo un mensaje de registro que dice using serial LDA version on this nodeAlgunas líneas después, veo otro ...
Cómo encurtir un objeto ssl.SSLContext
Python 3.5 en Windows, pruebe estos: import ssl, pickle, multiprocessing context = ssl.create_default_context() foo = pickle.dumps(context) pickle.loads(foo)Lanza una excepción: TypeError: __new__() missing 1 required positional argument: ...
El multiprocesamiento de Python genera continuamente procesos de pythonw.exe sin hacer ningún trabajo real
No entiendo por qué este código simple # file: mp.py from multiprocessing import Process import sys def func(x): print 'works ', x + 2 sys.stdout.flush() p = Process(target= func, args= (2, )) p.start() p.join() p.terminate() print 'done' ...
registro de Python con multiprocesamiento, registrador raíz diferente en Windows
Intenté iniciar sesión con multiprocesamiento, y encontré en Windows, obtendré diferentes registradores raíz en el proceso secundario, pero en Linux eso está bien. El código de prueba: main.py: #!/usr/bin/env python # -*- coding: utf-8 -*- ...
Multiprocesamiento de Python 3: tamaño de fragmento óptimo
¿Cómo encuentro el tamaño de fragmento óptimo paramultiprocessing.Pool ¿instancias? Utilicé esto antes para crear un generador den objetos sudoku: processes = multiprocessing.cpu_count() worker_pool = multiprocessing.Pool(processes) sudokus ...
Apio: ¿cómo limitar el número de tareas en la cola y dejar de alimentar cuando está lleno?
Soy muy nuevo en Apio y aquí está la pregunta que tengo: Supongamos que tengo un script que se supone que constantemente obtiene nuevos datos de DB y los envía a los trabajadores que usan Celery. task.py # Celery Task from celery import Celery ...
Python manager.dict () es muy lento en comparación con el dict regular
Tengo un dict para almacenar objetos: jobs = {} job = Job() jobs[job.name] = jobahora quiero convertirlo para usar manager dict porque quiero usar multiprocesamiento y necesito compartir este dict entre procesos mgr = multiprocessing.Manager() ...
Pasar múltiples parámetros a la función pool.map () en Python [duplicar]
Esta pregunta ya tiene una respuesta aquí: Python multiprocessing pool.map para múltiples argumentos [/questions/5442910/python-multiprocessing-pool-map-for-multiple-arguments] 18 respuestas Necesito alguna forma de usar una función dentro de ...
Comunicación de proceso del multiprocesamiento de Python
Aprendí sobre los tubos / colas / objetos / administradores de tipos compartidos de multiproceso de Python, y quiero compararlos con las tuberías anónimas de Linux, las tuberías con nombre, la memoria compartida, el socket, etc. Ahora tengo las ...
l rendimiento de multiprocesamiento de @Python solo mejora con la raíz cuadrada de la cantidad de núcleos utilizados
Estoy intentando implementar el multiprocesamiento en Python (Windows Server 2012) y tengo problemas para lograr el grado de mejora del rendimiento que espero. En particular, para un conjunto de tareas que son casi completamente independientes, ...