multiprocesamiento es un paquete que admite procesos de generación utilizando una API similar al módulo de subprocesamiento en lenguaje de programación python.

python-multiprocessing...

Tengo una función con varios parámetros, iterable_token, dataframe, label_array. Sin embargo, solo iterable_token es iterable en la función. def cross_tab(label,token_presence): A_token=0 B_token=0 C_token=0 D_token=0 for i,j in zip(list(label),list(token_presence)): if i....
3 ago. 2020 a las 10:11
Estoy experimentando con multiprocesamiento en Python (en una PC con Windows) y escribí un script de prueba para comparar las velocidades de un procedimiento simple con y sin multiprocesamiento. Lo que esperaba que hiciera esto era calcular tres exponenciales dos veces, una vez mediante multiprocesa....
Aquí está mi intento: int* globalvar = new int[8]; void cpp_init(){ for (int i = 0; i < 8; i++) globalvar[i] = 0; } void writeAtIndex(int index, int value){ globalvar[index] = value; } int accessIndex(int index){ return globalvar[index]; } BOOST_PYTHON_MODULE(MpUtils){ def("c....
Estoy tratando de leer varias líneas de un archivo a la vez para separar esas líneas en dos listas separadas. La función cleanLine esencialmente toma la línea que se alimenta y la limpia, devolviendo una línea sin espacios en blanco. En este momento, mi código se compila y devuelve los mismos result....
29 jun. 2020 a las 23:08
Así que he estado tratando de ejecutar dos funciones simultáneamente, pero una nunca parece funcionar a menos que detenga la otra. La primera función está destinada a enviar un correo electrónico cada 30 segundos (función probada por sí misma y funciona), la segunda es imprimir una declaración simpl....
Se cree que el marco Dask es capaz de manejar conjuntos de datos que tienen más de RAM de tamaño. Sin embargo, no pude aplicarlo con éxito a mi problema, que suena así: Tengo un gran archivo .csv (1.8Gb), que contiene textos de los comentarios de los usuarios, y una RAM de 8Gb. El objetivo es prepro....
Esperaba que si llamaba a apply_async en un método de instancia y obtuviera su resultado, cualquier cambio realizado seguiría siendo parte de los procesos bifurcados. Sin embargo, parece que cada nueva llamada a apply_async crea una nueva copia de dicha instancia. Toma el siguiente código: from mult....
13 may. 2020 a las 15:57
Estoy tratando de iniciar múltiples procesos dirigidos a una función con diferentes argumentos cada vez, me gustaría saber si hay una manera más conveniente de escribir esto: if __name__ == "__main__": p1 = multiprocessing.Process(target=get_articles, args=[1, 101, 1]) p2 = multiprocessi....
10 may. 2020 a las 01:04
Actualmente estoy enfrentando el error mencionado al ejecutar un código muy simple: Código: import multiprocessing as mp import time as t def do_something(): t.sleep(1) print("Done Sleeping") p1 = mp.process(target=do_something) p2 = mp.process(target=do_something) p1.start() p2.sta....
2 may. 2020 a las 16:06
Quiero que cada proceso tenga su propia copia de la variable global y el proceso debería poder modificar y almacenar la variable global: import multiprocessing from multiprocessing import Pool import time input = [1,10] first = 0 def printer (input) : global first first += input print('i....
Tengo un script que produce archivos a partir de un gran conjunto de datos, por lo que estoy usando multiprocesamiento para acelerar las cosas. El problema que tengo es que mi script acepta varios argumentos de línea de comando usando la biblioteca argparse que cambia los resultados y estoy luchando....
29 abr. 2020 a las 21:49
Estoy usando multiprocesamiento en python para mejorar el rendimiento del código. En lugar de agregar el resultado directamente en un marco de datos, estoy usando una lista común. df_list = mp.Manager().list() Los valores se calculan y agregan en la lista anterior por diferentes procesos. lock.acqu....
Estoy ejecutando una prueba paralela con Python 3.7 y Appium 1.15.1 en teléfonos inteligentes Android reales. Yo uso concurrent.futures.ProcessPoolExecutor para ejecutar cada prueba en cada teléfono inteligente. Estoy pasando la lista del uid de los teléfonos inteligentes a mi función de mapa. De ....
Estoy tratando de medir la ventaja de clase de grupo en módulo de multiprocesamiento sobre la programación normal y estoy calculando el cuadrado de un número usando una función. Ahora, cuando calculo el tiempo necesario para encontrar el cuadrado de los tres números, se tarda alrededor de ~ 0.2....
11 abr. 2020 a las 17:05
Estoy tratando de ejecutar, pausar y finalizar los procesos secundarios en Python desde el proceso primario. He intentado usar multiprocessing.Value pero por alguna razón el proceso padre nunca termina completamente aunque yo terminate y join todos los procesos. Mi caso de uso es algo como: def chil....
import multiprocessing import time data = ( ['a', '2'], ['b', '4'], ['c', '6'], ['d', '8'], ['e', '1'], ['f', '3'], ['g', '5'], ['h', '7'] ) def mp_worker(inputs, the_time): print(" Processs %s\tWaiting %s seconds" % (inputs, the_time)) time.sleep(int(the_time)) print(" Process....
15 mar. 2020 a las 02:43
Tengo este código que debería poner un evento en una cola cada vez que un programa externo (TCPdump) crea un archivo * .pcap en mi directorio. Mi problema es que siempre obtengo una cola vacía, aunque obtuve la función print de process (). ¿Qué estoy haciendo mal? ¿La cola está correctamente definid....
Al enviar una lista de tareas que es más larga que la cantidad de procesos, ¿cómo se asignan los procesos a estas tareas? from multiprocessing import Pool def f(i): print(i) return i with Pool(2) as pool: print(pool.map(f, [1, 2, 3, 4, 5])) Estoy ejecutando una función más compleja y ....
Tengo varias secuencias de comandos que ejecuto usando el grupo de multiprocesamiento. Estoy tratando de hacer una barra de progreso basada en las secuencias de comandos completadas. Revisé https://stackoverflow.com/questions/3173320/text- barra de progreso en la consola # = Pero no puedo entender....
7 mar. 2020 a las 22:12
Tengo un código como este import multiprocessing as mp processes = [] for i in range(10): p = mp.Process(target=my_func, args=args) processes.append(p) p.start() for p in processes: p.join() Si hay un error en my_func que hace que todos los hilos se bloqueen, entonces quiero que mi proces....
5 mar. 2020 a las 07:45
Soy nuevo en multiprocesamiento y python, desde la documentación, https://docs.python.org/3/library/multiprocessing.html Pude ejecutar el siguiente código. from multiprocessing import Pool def f(x): return x*x if __name__ == '__main__': with Pool(5) as p: print(p.map(f, [1, 2, 3])....
25 feb. 2020 a las 10:36
Estoy tratando de ejecutar algunos cálculos en bucle, cada cálculo crea, usa y cierra un grupo. Pero el cálculo solo se ejecuta una vez y luego arroja un error: "El grupo no se está ejecutando". Por supuesto, el anterior no se está ejecutando, pero ¿no debería crearse el nuevo? A continuación se mue....
Tengo un marco de datos de pandas de aproximadamente 2 millones de filas (80 columnas cada una). Me gustaría enviar el marco de datos a csv, así como a un archivo de parquet. Suponga que el marco de datos está presente en la variable df Enfoque inicial : print('Creating csv and parquet files') st =....
3 feb. 2020 a las 07:14
He creado un script simple que itera a través de una lista de servidores que necesito para hacer ping y nslookup. El problema es que hacer ping puede llevar algún tiempo, especialmente hacer ping a más servidores de los que son segundos en un día. Soy bastante nuevo en programación y entiendo que el....
En el ejemplo simple de Python 3 a continuación, donde usamos el módulo multiproessing para procesar la lista friends, qué está causando el error: TypeError: new () falta 1 argumento posicional requerido: 'nombre' No se produce ningún error si simplemente se ejecuta tom = Friend(tom) say_hello(tom....