python 后台的即发即忘异步函数

Question

我正在尝试以非阻塞方式执行异步无限循环函数。目前我有以下代码：

class OpcuaClient():
    def __init__(self):
        ...
        #subscribe to changes
        loop = asyncio.get_event_loop()
        loop.create_task(self.subscribe_to_node(self.type_Nid))
        loop.create_task(self.subscribe_to_node(self.housingSerial_Nid))
        loop.run_forever()
 
        print("subprocesses started")
 
    async def subscribe_to_node(self, nodeid):
        async with Client(url=self.url) as client:
            node = client.get_node(nodeid)
            # subscribing to node
            sub = await client.create_subscription(500, self.handler)
            await sub.subscribe_data_change(node)
            # subscribe for infinte time
            while True:
                await asyncio.sleep(1)

但是，loop.run_forever() 会阻止执行，并且“子进程已启动”永远不会被打印。请注意，我想在同步构造函数中启动后台进程。我怎样才能做到这一点？我还尝试了一些多处理/线程的东西，但也失败了。

Answer 1

一旦您启动事件循环（例如使用loop_forever），它就会接管控制权。 “永远”意味着直到没有明确停止为止。循环关闭后将到达以下打印消息的语句，但所有异步操作也会停止。

如果您需要将“后台”服务作为任务运行，则还需要将“前台”代码转换为异步任务，或者使用问题中提到的多线程或多处理，但不知道与预期通信的详细信息后台任务很难提出任何建议。

Answer 2

通过结合多线程和异步任务解决了我的问题，如 @norbeq 此处。