Articles of multiproceso de

Barra de progreso TTK bloqueada al enviar correo electrónico

Estoy escribiendo una aplicación en python usando tkinter. En esta aplicación estoy intentando enviar un lote de correos electrónicos y quiero mostrar una barra de progreso mientras se envían. Puedo crear la barra de progreso e iniciarla, pero cuando se envían los correos electrónicos, la barra simplemente se detiene (si se inicia mucho antes de […]

¿Cómo matar a este threading.Timer?

He lanzado un hilo usando un objeto Timer . Ahora, quiero detener este hilo pero no puedo. He utilizado cancel() , pero no funciona. No se por que import threading import time import sys as system def Nop(): print(“do nothing”) return 0 def function(): try: while True: print(“hello world “) time.sleep(2) except KeyboardInterrupt: print( “Good […]

Paralela un bucle nested en python para encontrar el valor máximo

Estoy luchando por algún tiempo para mejorar el tiempo de ejecución de este fragmento de código. Dado que los cálculos realmente requieren mucho tiempo, creo que la mejor solución sería paralelizar el código. La salida también se puede almacenar en la memoria, y luego escribirse en un archivo. Soy nuevo tanto en Python como en […]

Ejecutando múltiples sesiones de tensorflow al mismo tiempo

Estoy intentando ejecutar varias sesiones de TensorFlow simultáneamente en una máquina CentOS 7 con 64 CPU. Mi colega informa que puede usar los siguientes dos bloques de código para producir una aceleración paralela en su máquina usando 4 núcleos: mnist.py import numpy as np import input_data from PIL import Image import tensorflow as tf import […]

Obtener todos los artículos del hilo Queue

Tengo un hilo que escribe los resultados en una cola. En otro hilo (GUI), verifico periódicamente (en el evento IDLE) si hay resultados en la cola, como esto: def queue_get_all(q): items = [] while 1: try: items.append(q.get_nowait()) except Empty, e: break return items ¿Es esta una buena manera de hacerlo? Editar: Lo pregunto porque a […]

Python threading.Event () – Asegurar que todos los hilos en espera se activen en event.set ()

Tengo varios hilos que esperan en un evento, realizo alguna acción y luego espero en el evento nuevamente. Otro hilo activará el evento cuando sea apropiado. No puedo encontrar una manera de asegurar que cada subproceso en espera se active exactamente una vez que se haya configurado el evento. Actualmente tengo el hilo de activación […]

Multiprocesamiento de Python y manejo de excepciones en trabajadores.

Utilizo la biblioteca de multiprocesamiento de Python para un algoritmo en el que tengo muchos trabajadores que procesan ciertos datos y devuelven el resultado al proceso principal. Uso el multiprocesamiento. Asignación de un puesto para pasar los trabajos a los trabajadores, y segundo para recostackr resultados. Todo funciona bastante bien, hasta que el trabajador no […]

¿Por qué no hay clase Timer en el módulo de multiprocesamiento de Python?

Por lo tanto, el módulo de threading tiene una clase de Timer heredada de la clase Thread para ejecutar varias veces varias tareas. Me preguntaba por qué el módulo de multiprocesamiento no tiene algo así como una clase análoga de TimedProcess , por ejemplo, que se hereda de Process para ejecutar varias tareas repetidamente. Es […]

Calcular en el dataframe pandas al mismo tiempo

¿Es factible realizar múltiples cálculos grupales en el dataframe en pandas simultáneamente y recuperar esos resultados? Por lo tanto, me gustaría calcular los siguientes conjuntos de marcos de datos y obtener esos resultados uno por uno, y finalmente fusionarlos en un solo dataframe. df_a = df.groupby([“state”, “person”]).apply(lambda x: np.mean(x[“height”])) df_b = df.groupby([“state”, “person”]).apply(lambda x: np.mean(x[“weight”])) […]

temporizador de interrupción de hilo python

He estado tratando de hacer un temporizador preciso en Python, o como un sistema operativo lo permite. Pero parece ser más complicado de lo que inicialmente pensé. Así es como me gustaría que funcione: from time import sleep from threading import Timer def do_this(): print (“hello, world”) t = Timer(4, do_this) t.start() sleep(20) t.cancel() Donde […]