Python实现监听通知，发送通知，等待执行，执行结束继续监听下一个的功能例子

为了实现监听通知、发送通知、等待执行以及执行结束后继续监听下一个通知的功能，我们可以使用 Python 的 asyncio 库来编写异步代码。以下是一个具体的示例：

import asyncio

# 假设这是您的通知处理函数，模拟耗时操作
async def handle_notification(notification):
    print(f"Processing notification: {notification}")
    await asyncio.sleep(1)  # 模拟耗时操作
    print(f"Finished processing {notification}")

class NotificationListener:
    def __init__(self):
        self._queue = asyncio.Queue()
        self._processing = False

    async def listen(self):
        while True:
            notification = await self._queue.get()  # 等待新通知到来
            self._processing = True
            print(f"Received notification: {notification}")
            await handle_notification(notification)  # 处理通知
            self._processing = False

    async def send_notification(self, notification):
        if not self._processing:
            await self._queue.put(notification)  # 直接放入队列
        else:
            print(f"Delayed sending notification {notification} until processing finishes")

# 主程序
async def main():
    listener = NotificationListener()
    asyncio.create_task(listener.listen())  # 启动监听循环

    async def simulate_notifications():
        for i in range(5):
            await asyncio.sleep(3)  # 模拟间隔时间
            print(f"Sending notification {i+1}")
            await listener.send_notification(i+1)

    asyncio.create_task(simulate_notifications())

    await asyncio.sleep(20)  # 主程序运行一段时间后退出

if __name__ == "__main__":
    asyncio.run(main())

在这个示例中：

1. NotificationListener 类封装了监听通知、发送通知以及处理通知的逻辑。它包含一个 asyncio.Queue 对象用于存储待处理的通知，以及一个 _processing 标志位来指示当前是否正在处理通知。

2. listen 方法是一个异步方法，它在一个无限循环中等待队列中的新通知。当收到通知时，它会更新 _processing 标志并调用 handle_notification 进行处理。处理完成后，标志重置，准备接收下一个通知。

3. send_notification 方法用于发送通知。如果当前没有正在处理的通知，它直接将通知放入队列。否则，它打印一条消息表明通知将延迟发送，直到当前处理完成。

4. main 函数中，创建了一个 NotificationListener 实例并启动监听循环。同时启动一个异步任务 simulate_notifications 来模拟定期发送通知。主程序运行一段时间后（这里设置为 20 秒）退出。

这个示例实现了您所要求的功能：监听通知、发送通知、等待执行（处理通知）以及执行结束后继续监听下一个通知。通知的发送逻辑还考虑了避免在处理正在进行时添加新通知到队列，而是延迟发送，确保按顺序处理每个通知。实际应用中，您可以根据需求调整处理逻辑和通知发送策略。