Resultados de la búsqueda a petición "python-multiprocessing"
Faltan líneas al escribir archivos con multiprocesamiento Lock Python
Este es mi código: from multiprocessing import Pool, Lock from datetime import datetime as dt console_out = "/STDOUT/Console.out" chunksize = 50 lock = Lock() def writer(message): lock.acquire() with open(console_out, 'a') as ...
Python ejecuta cobertura en proceso interminable
Tengo un servidor web multiprocesado con procesos que nunca terminan, me gustaría verificar la cobertura de mi código en todo el proyecto en un entorno en vivo (no solo de las pruebas). El problema es que, dado que los procesos nunca terminan, ...
¿Cómo ejecutar mapas de multiprocesamiento pathos jerárquicos anidados?
Después de construir una parte importante de mi código en la serialización / decapado de eneldo, también estoy tratando de usar el multiprocesamiento pathos para paralelizar mis cálculos. Pathos es una extensión natural del eneldo. Al intentar ...
Multiprocesamiento de Python: ¿por qué los trozos grandes son más lentos?
He estado perfilando algún código usando el módulo de multiprocesamiento de Python (la función 'trabajo' simplemente cuadra el número). data = range(100000000) n=4 time1 = time.time() processes = multiprocessing.Pool(processes=n) results_list = ...
Keras + Tensorflow: predicción en múltiples gpus
Estoy usando Keras con tensorflow como back-end. Tengo un modelo compilado / entrenado. Mi ciclo de predicción es lento, así que me gustaría encontrar una forma de paralelizar elpredict_proba llama a acelerar las cosas. Me gustaría tomar ...
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 ...
¿Por qué la piscina multiproceso es más lenta que un bucle for?
from multiprocessing import Pool def op1(data): return [data[elem] + 1 for elem in range(len(data))] data = [[elem for elem in range(20)] for elem in range(500000)] import time start_time = time.time() re = [] for data_ in ...
¿Cuál es la diferencia entre ThreadPool y Pool en el módulo de multiprocesamiento Python?
Cuál es la diferencia entreThreadPool yPool enmultiprocessing módulo. Cuando pruebo mi código, esta es la principal diferencia que veo: from multiprocessing import Pool import os, time print("hi outside of main()") def hello(x): print("inside ...
grupo de multiprocesamiento no funciona en funciones anidadas
El siguiente 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): ...
¿Es seguro llamar multiprocesamiento desde un hilo en Python?
De acuerdo ahttps://github.com/joblib/joblib/issues/180 [https://github.com/joblib/joblib/issues/180]y¿Hay alguna forma segura de crear un subproceso desde un hilo en ...