管理 asyncio 任务

下面是一个示例代码，演示了如何使用asyncio模块来管理异步任务。

import asyncio

# 定义一个异步任务
async def my_task(id):
    print(f'Task {id} started')
    await asyncio.sleep(1)  # 模拟任务执行
    print(f'Task {id} completed')

# 定义一个任务管理函数
async def task_manager():
    tasks = []

    # 创建并添加异步任务到任务列表
    for i in range(5):
        task = asyncio.create_task(my_task(i))
        tasks.append(task)

    # 等待所有任务完成
    await asyncio.gather(*tasks)

# 运行任务管理函数
asyncio.run(task_manager())

在这个示例中，我们首先定义了一个异步任务my_task，它打印一条开始消息，然后等待1秒钟，最后打印一条完成消息。

然后，我们定义了一个任务管理函数task_manager，该函数创建了5个异步任务，并将它们添加到任务列表中。然后，我们使用asyncio.gather函数来等待所有任务完成。

最后，在主程序中调用asyncio.run函数来运行任务管理函数。

运行这个示例代码，你将看到输出的结果如下：

Task 0 started
Task 1 started
Task 2 started
Task 3 started
Task 4 started
Task 0 completed
Task 1 completed
Task 2 completed
Task 3 completed
Task 4 completed

这表明所有的异步任务都按顺序执行完成了。