Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Estoy teniendo un problema con ThreadPool cuando se usa como gestor de contexto. Cuando utilizo el método apply_async y trato de obtener los resultados con el método get(), simplemente se bloquea. El código proporcionado tiene el ThreadPool como gestor de contexto. Siempre se bloquea en la parte inferior cuando intento . . . Read more
Tengo dos scripts, a.py y b.py, que se envían datos entre sí a través del localhost (mqtt), y ambos dependen de un archivo de configuración config.json. Por lo general, los ejecuto en dos terminales diferentes. a.py en una terminal b.py en otra y todo está bien. Ahora estoy tratando de . . . Read more
Estoy preguntando si hay algo especial que necesite hacer para finalizar un trabajo de hilo en Flask. Aquí está el código de muestra: from flask import ( Flask, jsonify, render_template, request ) import threading import time import random app = Flask(__name__) def task(thread_return): random_seconds=random.random() print(f’Comenzar tarea {threading.current_thread().name}’) time.sleep(random_seconds*15) print(f’Terminar {threading.current_thread().name}’) . . . Read more
Estoy construyendo un algoritmo de trading en Python. Leo datos de una API de un bróker, que me permite suscribirme para recibir datos del mercado de diversos valores. Estoy tratando de encontrar patrones en el precio de las opciones. Idealmente, me suscribiría a miles de datos en tiempo real de . . . Read more
Cuando pongo un intervalo grande para ejecutar el programa, este termina sin ejecutar la función dada (join no resuelve el problema) from threading import Timer class TimerThread: def __init__(self, delay_time, thread_function): self.delay_time = delay_time self.thread_function = thread_function self._timer = None def run_repeatedly(self): self.thread_function() self._timer = Timer(self.delay_time, self.run_repeatedly) self._timer.start() self._timer.join() timer . . . Read more