Articles of asíncrono

Python Tornado – La solicitud asíncrona está bloqueando

Los manejadores de solicitudes son los siguientes: class TestHandler(tornado.web.RequestHandler): # localhost:8888/test @tornado.web.asynchronous def get(self): t = threading.Thread(target = self.newThread) t.start() def newThread(self): print “new thread called, sleeping” time.sleep(10) self.write(“Awake after 10 seconds!”) self.finish() class IndexHandler(tornado.web.RequestHandler): # localhost:8888/ def get(self): self.write(“It is not blocked!”) self.finish() Cuando OBTENGO localhost:8888/test , la página carga 10 segundos y muestra […]

Tornado AsyncHTTPClient fetch callback: Parámetros extra?

Soy un poco nuevo en todo este juego asíncrono (en su mayoría ha sido un tipo de Django), pero me preguntaba: ¿cómo puedo pasar parámetros extra a la callbacks de AsyncHTTPClient.fetch de Tornado? Por ejemplo, estoy rastreando el número de veces que se ha llamado una callback (para esperar hasta que un número determinado se […]

cómo realizar un seguimiento de los resultados asíncronos devueltos desde un grupo de multiprocesamiento

Estoy tratando de agregar multiprocesamiento a algún código que incluye funciones que no puedo modificar. Deseo enviar estas funciones como trabajos a un grupo de multiprocesamiento de forma asíncrona. Estoy haciendo algo parecido al código que se muestra aquí . Sin embargo, no estoy seguro de cómo realizar un seguimiento de los resultados. ¿Cómo puedo […]

¿Poner en cola las llamadas remotas a un agente de perspectiva de Python Twisted?

La fuerza de Twisted (para python) es su marco asíncrono (creo). He escrito un servidor de procesamiento de imágenes que recibe solicitudes a través de Perspective Broker. Funciona bien siempre que lo alimente con menos de un par de cientos de imágenes a la vez. Sin embargo, a veces se le añaden cientos de imágenes […]

¿Cómo funciona el entrenamiento asíncrono en Tensorflow distribuido?

He leído Distributed Tensorflow Doc , y menciona que en el entrenamiento asíncrono, Cada réplica del gráfico tiene un ciclo de entrenamiento independiente que se ejecuta sin coordinación. Por lo que entiendo, si utilizamos el servidor de parámetros con una architecture de paralelismo de datos, significa que cada trabajador calcula los gradientes y actualiza sus […]

Progtwigción asíncrona en Python Twisted

Estoy teniendo problemas para desarrollar un proxy inverso en Twisted. Funciona, pero parece demasiado complejo y complicado. Mucho de eso se siente como vudú. ¿Hay ejemplos simples y sólidos de estructura de progtwigs asíncronos en la web o en los libros? ¿Una especie de guía de mejores prácticas? Cuando complete mi progtwig, me gustaría poder […]

¿Cómo funciona el sondeo largo en Tornado?

En la demostración de chat de Tornado, tiene un método como este: @tornado.web.asynchronous def post(self): cursor = self.get_argument(“cursor”, None) global_message_buffer.wait_for_messages(self.on_new_messages, cursor=cursor) Soy bastante nuevo en este tema de sondeo largo, y realmente no entiendo exactamente cómo funcionan los hilos, aunque dice: Al utilizar E / S de red sin locking, Tornado puede escalar a decenas […]

Cómo agregar un tiempo de espera a una función en Python

En el pasado, se han realizado muchos bashs para agregar la funcionalidad de tiempo de espera en Python, de modo que cuando un límite de tiempo especificado caduque, el código de espera podría continuar. Desafortunadamente, las recetas anteriores permitieron que la función en ejecución continuara ejecutando y consumiendo recursos, o bien eliminaron la función utilizando […]

¿Usar un generador de python simple como una co-rutina en un controlador asíncrono Tornado?

Tengo una función de generador de python que produce trozos de texto. Me gustaría escribir un método de get para una subclase tornado.web.RequestHandler que tornado.web.RequestHandler el generador, escribiendo los fragmentos en la respuesta a medida que avanza. Dado que esto es Tornado, y dado que el generador puede tardar más de un segundo en procesarse, […]

Progtwigción asíncrona en python.

¿Existe una noción genérica de progtwigción asíncrona en python? ¿Puedo asignar una callback a una función, ejecutarla y volver al flujo principal del progtwig inmediatamente, sin importar cuánto tiempo tome la ejecución de esa función?