协程(微线程),轻量级线程,其完全由程序自身控制执行流程,而不是操作系统内核调度,这样协程切换开销极小,可以在单线程内实现高并发。在 Python 中,协程通过async/await关键字实现。async 可定义异步函数,await 用在异步函数中等待一个异步操作(如I/O操作)的完成。
使用 async 定义的函数称为异步函数,异步函数内部可用 await表示
等待异步操作(如网络请求、文件读写等)的完成。等待期间,函数会挂起,控制权给其他任务,实现并发执行。
在异步函数中,使用 await 等待一个异步操作的完成。await后面通常跟一个异步调用表达式(如await some_async_function()),该表达式会返回一个Future或Awaitable对象。当这个对象表示的操作完成时,await表达式会恢复执行,并返回操作的结果。
import asyncioasync def delay_demo(sleep_time):print(f"start delay {sleep_time}")await asyncio.sleep(sleep_time)print(f"end delay {sleep_time}")async def main():tasks = [delay_demo(2), delay_demo(1), delay_demo(3)]await asyncio.gather(*tasks)asyncio.run(main()) 输出结果: start delay 2 start delay 1 start delay 3 end delay 1 end delay 2 end delay 3
上述代码实现了并发执行,异步操作由事件循环(Event Loop)调度和管理,不断检查是否有已完成的异步操作,恢复相应的异步函数执行,在一个线程内实现高并发,充分利用系统资源。
注意,在异步函数中,应尽量避免使用阻塞操作(如同步I/O、CPU密集型计算等),以免阻塞事件循环并降低并发性能。
参考:
Python协程探秘:async/await的魔法_await在协程中的作用-CSDN博客