如何为async事件循环添加动作事件？wxGUI异步事件绑定求助

问题核心 #

wxPython的事件处理为同步机制，无法直接绑定异步回调；同时asyncio事件循环已在运行服务器监听任务，不能用run_until_complete阻塞调用异步的send_message，轮询方案资源消耗过高。

解决方案 #

1. 同步事件回调中提交异步任务

修改MyFrame的on_press方法，不再直接调用异步函数，而是通过asyncio.create_task将发送任务提交到运行中的事件循环：

def on_press(self, event):
    message = self.text_ctrl.GetValue()
    self.text_ctrl.Clear()
    # 将异步发送任务提交到asyncio事件循环
    asyncio.create_task(send_message(self.writer, message))

2. 协同wx与asyncio事件循环

wx需要独立的事件循环，通过在asyncio任务中定期处理wx事件，实现两个循环的协同，避免GUI卡顿或异步任务阻塞：

async def launch_gui(reader, writer, room):
    app = wx.App()
    frame = MyFrame(reader, writer, room)
    frame()
    # 定期处理wx事件，平衡GUI响应与异步任务执行
    while True:
        app.Yield()
        await asyncio.sleep(0.01)

3. 调整服务器监听任务逻辑

原代码中event的使用可能导致不必要的阻塞，启动GUI时直接创建异步任务即可，无需依赖事件同步：

async def listen_server_event(reader, writer, event):
    while True:
        try:
            reply = await recv_message(reader)
            if reply:                
                print(reply)
            if "somemessage" in reply:
                room = reply.split(" ")[2]
                # 异步启动GUI，不阻塞当前监听任务
                asyncio.create_task(launch_gui(reader, writer, room))
        except asyncio.CancelledError:
            break

4. 确保异步函数正确性

确认send_message是标准的asyncio异步实现：

async def send_message(writer, message):
    writer.write(message.encode())
    await writer.drain()

原理说明 #

• asyncio.create_task可在不阻塞同步回调的前提下，将异步任务加入事件队列执行，完美适配wx的同步事件机制。
• 定期调用app.Yield()让wx处理GUI事件，结合asyncio.sleep(0.01)避免占用过多CPU资源，替代高消耗的轮询方案。

内容的提问来源于stack exchange，提问作者mechanics