def stop(self):
self.send("irrelevant", np.array([]), msg="done")
self.stopped = True
pending = asyncio.Task.all_tasks(loop=self._loop)
self._loop.stop()
time.sleep(1)
for task in pending:
task.cancel()
try:
self._loop.run_until_complete(task)
except asyncio.CancelledError:
pass
self._loop.close()
评论列表
文章目录