MagicStack / MagicStack/uvloop
How to stop event loop in child thread ?
オープン
まだ誰も着手していません。
- 主要言語
- Cython
- スター
- 11.9k
- フォーク
- 616
- PR マージ指標
- 30日以内にマージされた PR はありません
説明
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:
コントリビューションガイド
このリポジトリのコントリビューションガイドは索引されていません
はじめの一歩
- issue を最後まで読み、次にプロジェクトのコントリビューションガイドを読みます。
- 着手することを issue にコメントします — 二人が同じ作業をするのを防げます。
- リポジトリをフォークし、ブランチを切って変更します。
- issue 番号を参照したプルリクエストを送ります。
調査の方向性
まず、提供された Python 3.7.2、uvloop 0.14.0、macOS の環境を使って、_thread_main、run_forever、stop の間の相互作用を再現します。Issue に示されている loop と server のライフサイクル呼び出しを調査し、その後、親スレッドから停止した場合に正常に完了するかを確認します。サポートされている動作または必要な変更を文書化します。
索引モデルが issue の本文から書いたものです。
評価
- 技術スタック
- python
- 領域
- backend
- issue の種類
- バグ
- 難易度
- 4/5
- 見積もり時間
- 3〜5日
- 活発さ
- 停滞
- 明瞭さ
- おおむね明確
- 初心者へのやさしさ
- 30/100