Necesito imprimir un mensaje cada x segundos, al mismo tiempo , necesito escuchar la entrada del usuario. Si se presiona ‘q’, debería matar el progtwig. Por ejemplo some message . . # after specified interval . some message q # program should end El problema actual al que me enfrento ahora es que raw_input está […]
Quiero pasar argumentos con nombre a la función de destino, al crear un objeto Thread. El siguiente es el código que he escrito: import threading def f(x=None, y=None): print x,y t = threading.Thread(target=f, args=(x=1,y=2,)) t.start() Recibo un error de syntax para “x = 1”, en la Línea 6. Quiero saber cómo puedo pasar los argumentos […]
Me encontré con esta statement interesante en la sección “Advertencias” de la documentación para el módulo de thread hoy: No todas las funciones integradas que pueden bloquear la espera de E / S permiten que se ejecuten otros subprocesos. (Los más populares ( time.sleep() , file.read() , select.select() ) funcionan como se espera.) Casi en […]
Tengo un objeto de datos globales compartidos en mi servidor django de procesos múltiples de proceso único, un objeto que se usa con frecuencia, pero se calcula con poca frecuencia. El cálculo lleva mucho tiempo, por lo que quiero compartir los resultados. Pensé que funcionaría usar LocalMemCache de django para estos datos simples. Curiosamente, parece […]
Estoy usando la clase ThreadPoolExecutor del paquete concurrent.futures def some_func(arg): # does some heavy lifting # outputs some results from concurrent.futures import ThreadPoolExecutor with ThreadPoolExecutor(max_workers=1) as executor: for arg in range(10000000): future = executor.submit(some_func, arg) pero necesito limitar el tamaño de la cola de alguna manera, ya que no quiero que se creen millones de […]
import threading def read_file(): f = open(‘text.txt’) for line in f: print line.strip() ,’ : ‘, threading.current_thread().getName() if __name__ == ‘__main__’: threads = [] for i in range(15): t = threading.Thread(target=read_file) threads.append(t) t.start() Pregunta: ¿Cada subproceso leerá cada línea solo una vez del archivo de arriba o hay posibilidades de que un subproceso dado pueda […]
Estoy haciendo una aplicación webscraping en Python con el framework web Django. Necesito descartar múltiples consultas usando la biblioteca de beautifulsoup. Aquí está la instantánea del código que he escrito: for url in websites: r = requests.get(url) soup = BeautifulSoup(r.content) links = soup.find_all(“a”, {“class”:”dev-link”}) De hecho, aquí, el raspado de la página web se realiza […]
Tengo que grabar un archivo wav y al mismo tiempo tengo que analizarlo con sox. Estoy usando el archivo de tipo fifo para esta operación. Así que aquí necesito comenzar 2 hilos al mismo tiempo, pero incluso si uso los hilos no puedo lograr lo que quiero hacer. Siempre uno ejecutando primero y luego el […]
¿Cómo puedo verificar si el subproceso principal está vivo desde otro subproceso (no daemon, secundario)? El subproceso secundario es un subproceso no daemon y me gustaría comprobar si el subproceso principal todavía se está ejecutando o no, y detener este subproceso no daemon según el resultado. (Hacer el daemon de subprocesos no es bueno para […]
He estado tratando de crear una ventana de nivel superior de tkinter que transmita video desde la cámara web y realice un escaneo QR. Obtuve este código de escaneo QR de SO y otro código que solo actualiza las imágenes de la cámara web en lugar de transmitir el video en una etiqueta tkinter. y […]