基于Asyncio的pyModbus服务器：循环任务与优雅停止方案咨询

问题1：如何通过Ctrl+C优雅停止服务器，避免大量错误？ #

核心是先完成后台任务的清理，再关闭pyModbus服务器：

• 用asyncio.gather()统一管理所有任务（包括服务器、串口检查等任务），替代逐个await的阻塞执行方式。
• 捕获KeyboardInterrupt后，主动取消所有未完成的任务，等待它们执行完清理逻辑（如关闭串口、释放资源）。
• 调用pyModbus异步服务器的shutdown()和close()方法，确保服务器断开连接、释放端口，避免报错。

问题2：如何实现循环执行的任务（如每500ms刷新服务器数据）？ #

无需依赖第三方库，用原生asyncio即可实现，还能灵活控制定时精度：

• 基础循环实现（适合对定时精度要求不高的场景，任务执行时间会计入间隔）：

async def periodic_status_check():
    try:
        while True:
            # 写入检查串口状态、更新服务器数据的逻辑
            await asyncio.sleep(0.5)
    except asyncio.CancelledError:
        # 添加清理逻辑，比如关闭串口连接
        raise

• 高精度定时实现（严格按间隔执行，不受任务耗时影响）：

import time

async def precise_periodic(func, interval):
    try:
        last_run = time.time()
        while True:
            await func()
            # 计算抵消任务耗时后的sleep时长
            sleep_time = interval - (time.time() - last_run)
            if sleep_time > 0:
                await asyncio.sleep(sleep_time)
            last_run = time.time()
    except asyncio.CancelledError:
        pass

可将具体刷新逻辑封装成独立函数，传入precise_periodic实现复用。

问题3：关闭应用时，如何在停止服务器前优雅取消所有无限循环任务？ #

按以下步骤执行：

1. 捕获退出信号：在main函数中用try/except捕获asyncio.CancelledError，或给事件循环添加SIGINT信号处理器。
2. 取消所有任务：遍历已创建的任务，对未完成的任务调用task.cancel()，再通过await task等待其完成清理（任务内部需正确捕获CancelledError，执行清理后重新抛出）。
3. 关闭服务器：待所有任务清理完成后，调用pyModbus服务器的关闭方法，确保资源释放。
4. 退出事件循环：asyncio.run()会自动处理事件循环的停止，无需手动操作。

你的循环任务代码分析与修正 #

原代码存在的问题 #

• main中逐个await task会导致任务串行执行：第一个无限循环任务永远不会结束，第二个任务根本无法启动。
• 收到Ctrl+C时，仅第一个任务会被取消，第二个任务会在后台残留，无法完成优雅清理。

修正后的代码（支持并发执行与优雅取消） #

import asyncio

async def periodic():
    try:
        while True:
            print('periodic')
            await asyncio.sleep(1)
    except asyncio.CancelledError:
        print('task1 已取消，执行清理')
        # 添加实际资源清理逻辑，比如关闭串口
        raise  # 必须重新抛出，让await确认任务完成取消

async def periodic2():
    try:
        while True:
            print('periodic2')
            await asyncio.sleep(0.5)
    except asyncio.CancelledError:
        print('task2 已取消，执行清理')
        # 添加清理逻辑
        raise

async def main():
    # 创建并发任务
    tasks = [
        asyncio.create_task(periodic()),
        asyncio.create_task(periodic2())
    ]
    try:
        await asyncio.gather(*tasks)
    except asyncio.CancelledError:
        # 取消所有未完成任务
        for task in tasks:
            if not task.done():
                task.cancel()
                try:
                    await task
                except asyncio.CancelledError:
                    pass

if __name__ == "__main__":
    try:
        asyncio.run(main())
    except KeyboardInterrupt:
        print('收到Ctrl+C，开始优雅退出')

代码正确性说明 #

• 任务内部捕获CancelledError后重新抛出，确保await task能等待清理完成。
• 用asyncio.gather()实现任务并发，所有任务可同时执行。
• 收到Ctrl+C后，所有任务都会被取消并执行清理逻辑，实现正确的资源释放。

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