使用使用asyncio事件循环线程的表示形式记录对象会停止脚本

Question

我一直试图使用pythonwebsocket库为websocket服务器创建一个客户端，但遇到了一个无法修复的错误

当记录使用asyncio库的对象时，脚本似乎无缘无故地停止

这不是什么关键的事情，但它困扰着我，我不想让它在今后的道路上造成问题

下面是一个示例代码，它再现了这一点：

#!/usr/bin/python3
# -*- coding: utf-8 -*-

import asyncio
import logging

from threading import Thread

logger = logging.getLogger(__name__)


class Main(Thread):
    def __init__(self):
        Thread.__init__(self, daemon=True)
        self.loop = asyncio.get_event_loop()
        self.running = True
        logger.debug("Init")

    def run(self):
        """ Starts the main loop in the thread """
        logger.debug("Thread Started")
        asyncio.set_event_loop(self.loop)
        # self.main_task = asyncio.run_coroutine_threadsafe(
        #     self._mainloop(), self.loop)
        # self.loop.run_forever()
        self.loop.run_until_complete(self._mainloop())
        logger.debug("Thread Finished")

    async def _mainloop(self):
        """ Async main loop """
        while self.running:
            await self.wait(0.1, "_mainloop")
            logger.debug("Test loop")

    async def wait(self, t, text):
        """ Example async function """
        logger.debug("Wait... %s", text)
        await asyncio.sleep(t)
        logger.debug("Wait ok %s", text)
        return "Main object"

    def __repr__(self):
        """ Uses an async function to get the repr """
        fut = asyncio.run_coroutine_threadsafe(
            self.wait(0, "__repr__"), self.loop)
        return fut.result()

    def close(self):
        """ Waits for the main loop to end """
        logger.debug("Closing...")
        self.running = False
        self.join()
        # self.main_task.result()
        logger.debug("Closing ok")


if __name__ == "__main__":
    FORMAT = '%(name)-8s %(threadName)-10s %(levelname)-8s %(message)s'
    logging.basicConfig(level=logging.DEBUG, format=FORMAT)

    logger.info("Start")

    m = Main()
    m.start()

    logger.info("1 %s", repr(m))  # Works fine
    logger.info("2 %s", str(m))   # Works fine
    logger.info("3 %s" % m)       # Works fine
    logger.info("4 %s", m)        # Halts
    logger.info(str(m))           # Works fine
    logger.info(m)                # Also halts

    m.close()

    logger.info("End")

到停止点的输出：

__main__ MainThread INFO     Start
asyncio  MainThread DEBUG    Using proactor: IocpProactor
__main__ MainThread DEBUG    Init
__main__ Thread-1   DEBUG    Thread Started
__main__ Thread-1   DEBUG    Wait... _mainloop
__main__ Thread-1   DEBUG    Wait... __repr__
__main__ Thread-1   DEBUG    Wait ok __repr__
__main__ MainThread INFO     1 Main object
__main__ Thread-1   DEBUG    Wait... __repr__
__main__ Thread-1   DEBUG    Wait ok __repr__
__main__ MainThread INFO     2 Main object
__main__ Thread-1   DEBUG    Wait... __repr__
__main__ Thread-1   DEBUG    Wait ok __repr__
__main__ MainThread INFO     3 Main object

注释了两条阻塞行后，脚本继续：

__main__ MainThread INFO     3 Main object
__main__ MainThread DEBUG    Closing...
__main__ Thread-1   DEBUG    Wait ok _mainloop
__main__ Thread-1   DEBUG    Test loop
__main__ Thread-1   DEBUG    Thread Finished
__main__ MainThread DEBUG    Closing ok
__main__ MainThread INFO     End

查看日志源代码，我还没有找到可以解释这一点的东西。 https://github.com/python/cpython/blob/0bc17658f5724ce60c3f75acc01e7526f1720efe/Lib/logging/__init__.py#L365-L368

我尝试过创建asyncio事件循环的不同方法，但没有任何区别

我的代码有问题吗？这是使用异步IO和线程的正确方法吗

我正在使用Python 3.9.6和日志记录0.5.1.2（如果有帮助的话）