MagicStack / MagicStack/uvloop
How to stop event loop in child thread ?
Aperta
Nessuno ha ancora preso questa issue.
- Lingua principale
- Cython
- Stelle
- 11.9k
- Fork
- 616
- Metriche di merge delle PR
- Nessuna PR unita negli ultimi 30g
Descrizione
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:
Guida per i contributori
Nessuna guida per i contributori indicizzata per questo repository
Come iniziare
- Leggi tutta la issue e poi la guida ai contributi del progetto.
- Commenta sulla issue per dire che te ne occupi tu — evita che due persone facciano lo stesso lavoro.
- Fai un fork del repository e lavora su un branch.
- Apri una pull request che faccia riferimento al numero della issue.
Direzione di ricerca
Inizia riproducendo l’interazione tra _thread_main, run_forever e stop con la configurazione fornita di Python 3.7.2, uvloop 0.14.0 e macOS. Esamina le chiamate del ciclo di vita del loop e del server mostrate nell’issue, quindi verifica se l’arresto dal thread padre viene completato correttamente. Documenta il comportamento supportato o la modifica necessaria.
Scritto dal modello di indicizzazione a partire dal testo della issue.
Valutazione
- Stack tecnologico
- python
- Ambito
- backend
- Tipo di issue
- Bug
- Difficoltà
- 4/5
- Tempo stimato
- 3-5 giorni
- Stato di attività
- Ferma
- Chiarezza
- Abbastanza chiara
- Idoneità per principianti
- 30/100