code: def run(self) -> None:
          
          if self.loop is None:
              return
          create_server = asyncio.ensure_future(self._run(), loop=self.loop)  # type: ignore
          try:
              self.loop.run_until_complete(create_server)
              self.loop.run_until_complete(self._check_alive())
          finally:
              self.loop.run_until_complete(self.loop.shutdown_asyncgens())
              self.loop.close()
docs: 创建了 sock 的运行回调