MagicStack / MagicStack/uvloop
How to stop event loop in child thread ?
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
- Lee el issue completo y luego la guía de contribución del proyecto.
- Comenta en el issue que vas a ocuparte — evita que dos personas hagan lo mismo.
- Haz un fork del repositorio y trabaja en una rama.
- 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