当前位置：首页 > news >正文

1 asyncio模块

news 2025/7/13 6:41:24

1.1核心概念

1.1.1协程

协程是一种特殊的函数，可以在执行过程中暂停，也可以稍后恢复执行。协程通过async关键字来指定。

await关键字：如果想要立即执行，那调用协程的时候，前面加上await关键字。只想创建协程对象稍后执行的话不用加await

1.1.2 事件循环

1.1.3 任务

任务是对协程的封装

封装方式：asyncio.create_task(协程)

例子

async def main():task = asyncio.create_task(say_hello())#创建任务，返回协程对象taskawait task#执行任务

1.1.4 并发

单cpu，在不同时间段执行两个不同的任务

1.1.5 并行

多个cpu同时运行

1.1.6 事件循环

事件循环是 asyncio 的核心组件，负责调度和执行协程。它不断地检查是否有任务需要执行，并在任务完成后调用相应的回调函数

async def main():await say_hello()asyncio.run(main())#创建一个事件循环

1.2 基本概念

1.2.1 运行协程

要运行一个协程，你可以使用 asyncio.run() 函数。它会创建一个事件循环，并运行指定的协程

例

import asyncioasync def main():print("Start")await asyncio.sleep(1)print("End")asyncio.run(main())

1.2.2 并发执行多个任务

使用 asyncio.gather() 函数并发执行多个协程，并等待它们全部完成。

import asyncioasync def task1():print("Task 1 started")await asyncio.sleep(1)print("Task 1 finished")async def task2():print("Task 2 started")await asyncio.sleep(2)print("Task 2 finished")async def main():await asyncio.gather(task1(), task2())asyncio.run(main())

1.2.3 超时控制

使用 asyncio.wait_for() 函数为协程设置超时时间。如果协程在指定时间内未完成，将引发 asyncio.TimeoutError 异常

import asyncioasync def long_task():await asyncio.sleep(10)print("Task finished")async def main():try:await asyncio.wait_for(long_task(), timeout=5)except asyncio.TimeoutError:print("Task timed out")asyncio.run(main())

查看全文

http://www.xdnf.cn/news/539137.html