MagicStack / MagicStack/uvloop

How to stop event loop in child thread ?

Abierto
#370 2 comentarios 0 reacciones 0 asignados Ver en GitHub

Nadie ha tomado este issue todavía.

Lenguaje dominante
Cython
Estrellas
11.9k
Forks
616
Métricas de merge de PR
Sin PR fusionados en 30 d

Descripción

I call the stop method in child thread,but loop’s state is running ~
Can you help me ?

import time
import asyncio
import threading
from functools import partial

import sanic
import uvloop


class ApiService:

    def __init__(self):
        self.__server = None
        self.__loop = None

    def _thread_main(self, loop):
        app = sanic.Sanic("Api")
        asyncio.set_event_loop(loop)
        serv_coro = app.create_server(
            host="0.0.0.0", port=8080, return_asyncio_server=True, debug=False
        )

        serv_task = asyncio.ensure_future(serv_coro, loop=self.__loop)
        self.__server = self.__loop.run_until_complete(serv_task)
        self.__server.after_start()
        self.__loop.run_forever()

    def run(self):
        self.__loop = uvloop.new_event_loop()
        # print(dir(self.__loop))
        # self._thread_main(self.__loop)
        thread = threading.Thread(
            target=partial(self._thread_main, self.__loop), name="api-service"
        )
        thread.setDaemon(True)
        thread.start()
        # thread.join()

    def stop(self):
        if self.__loop is None or self.__server is None:
            return

        self.__loop.stop()
        self.__server.before_stop()
        print(self.__loop)
        # Wait for server to close
        self.__loop.run_until_complete(self.__server.close())

        # Complete all tasks on the loop
        for connection in self.__server.connections:
            connection.close_if_idle()
        self.__server.after_stop()


if __name__ == '__main__':

    app = ApiService()
    try:
        app.run()
        while True:
            time.sleep(10)
    except (KeyboardInterrupt, InterruptedError) as _:
        print(app._ApiService__loop)
    except Exception as e:
        pass
    finally:
        app.stop()
  • uvloop:0.14.0:
  • python:3.7.2:
  • MacOS10.15.7:

Guía de contribución

No hay ninguna guía de contribución indexada para este repositorio

Primeros pasos

  1. Lee el issue completo y luego la guía de contribución del proyecto.
  2. Comenta en el issue que vas a ocuparte — evita que dos personas hagan lo mismo.
  3. Haz un fork del repositorio y trabaja en una rama.
  4. Abre un pull request que haga referencia al número del issue.

Línea de trabajo

Comienza reproduciendo la interacción entre _thread_main, run_forever y stop con la configuración proporcionada de Python 3.7.2, uvloop 0.14.0 y macOS. Inspecciona las llamadas del ciclo de vida del bucle y del servidor mostradas en el issue, y luego verifica si detenerlo desde el hilo padre se completa correctamente. Documenta el comportamiento compatible o el cambio necesario.

Escrito por el modelo de indexación a partir del texto del issue.

Evaluación

Stack tecnológico
python
Área
backend
Tipo de issue
Error
Dificultad
4/5
Tiempo estimado
3-5 días
Estado de actividad
Estancado
Claridad
Bastante claro
Aptitud para principiantes
30/100

Recibe los nuevos issues en tu correo

Un resumen breve de issues de GitHub para principiantes.