如何在同一脚本中实现非阻塞UDP服务器与定时任务？

你的需求完全可行，借助Python的asyncio异步框架，可以同时实现UDP服务器的持续运行和非阻塞的定时全局变量更新，无需使用阻塞式的while True。

核心实现思路 #

1. UDP服务器异步运行：通过asyncio.create_datagram_endpoint创建UDP服务器，它会注册到事件循环中，自动处理客户端请求，无需手动编写循环。
2. 非阻塞定时任务：用asyncio.create_task启动定时更新协程，协程内部用await asyncio.sleep()实现间隔等待，这会主动让出事件循环控制权，不会阻塞UDP服务的运行。

完整代码示例 #

import asyncio

# 全局变量
global_state = "初始值"

async def periodic_update():
    """每5分钟更新全局变量的非阻塞定时任务"""
    while True:
        # 等待5分钟（300秒），此过程中事件循环可处理其他任务
        await asyncio.sleep(300)
        global global_state
        # 替换为你的实际更新逻辑
        global_state = f"更新于 {asyncio.get_event_loop().time():.2f}"
        print(f"全局变量已更新: {global_state}")

class UDPHandler(asyncio.DatagramProtocol):
    def datagram_received(self, data, addr):
        # 处理收到的UDP消息
        request = data.decode("utf-8")
        print(f"来自 {addr} 的请求: {request}")
        # 携带全局变量值返回响应
        response = f"当前全局状态: {global_state}".encode("utf-8")
        self.transport.sendto(response, addr)

async def main():
    loop = asyncio.get_running_loop()
    
    # 启动UDP服务器
    transport, _ = await loop.create_datagram_endpoint(
        lambda: UDPHandler(),
        local_addr=("0.0.0.0", 9000)
    )
    
    # 启动定时更新任务（加入事件循环，非阻塞）
    asyncio.create_task(periodic_update())
    
    # 保持程序运行，直到收到中断信号（如Ctrl+C）
    try:
        await asyncio.Future()  # 无限等待，不占用事件循环资源
    finally:
        transport.close()

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

关键细节说明 #

• UDP服务器持续运行：create_datagram_endpoint创建的服务器会自动绑定端口并监听，只要事件循环在运行，就会一直处理请求。主协程里的await asyncio.Future()用来阻止程序退出，它不会阻塞事件循环，其他协程可以正常执行。
• 定时任务非阻塞：periodic_update里的while True配合await asyncio.sleep()是异步循环，每次sleep时事件循环会切换到UDP处理任务，不会出现互相阻塞的情况。
• 全局变量同步：所有任务都在同一个事件循环（单线程）中运行，不需要额外的锁机制来保护全局变量，避免了多线程的同步复杂问题。

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