0

0

如何使用asyncio库进行异步编程?

betcha

betcha

发布时间:2025-09-04 12:52:01

|

193人浏览过

|

来源于php中文网

原创

答案:asyncio通过协程、事件循环和任务实现高效异步I/O,核心是async/await机制,避免阻塞并提升并发性能。协程由事件循环调度,任务是协程的封装,实现并发执行。常见陷阱包括使用阻塞调用和忘记await,应使用异步库、连接池、async with管理资源。调试可用asyncio调试模式和IDE支持,测试推荐pytest-asyncio和模拟技术,确保异步逻辑正确性和稳定性。

如何使用asyncio库进行异步编程?

Python的

asyncio
库是处理并发I/O操作的核心工具,它通过事件循环和协程机制,让开发者能够以非阻塞的方式编写代码,显著提升程序在等待外部资源(如网络请求、文件读写)时的效率。简单来说,它让你能“同时”做很多事情,而不用真的开启多个线程或进程,从而避免了传统多线程带来的复杂性和开销。

在Python中,使用

asyncio
进行异步编程,核心就是理解并运用
async
await
这两个关键字。它们允许你定义可暂停和恢复的函数(协程),并在等待某个操作完成时,将控制权交还给事件循环,让其他任务得以运行。这就像你在厨房做饭,把水烧上后,你不会傻等着水开,而是去切菜、洗碗,等水开了再回来处理。

要真正上手

asyncio
,我们得从一个最基础的例子开始,体会它那种“等而不堵”的魔力。

import asyncio
import time

async def fetch_data(delay, data_id):
    """模拟一个异步的网络请求或IO操作"""
    print(f"任务 {data_id}: 开始获取数据,预计耗时 {delay} 秒...")
    await asyncio.sleep(delay)  # 这是一个非阻塞的等待
    print(f"任务 {data_id}: 数据获取完毕!")
    return f"Data from {data_id} after {delay}s"

async def main():
    start_time = time.monotonic() # 使用 monotonic 计时,避免系统时间调整影响

    # 同时运行多个异步任务
    results = await asyncio.gather(
        fetch_data(3, "API_1"),
        fetch_data(1, "DB_Query"),
        fetch_data(2, "File_Read")
    )

    end_time = time.monotonic()
    print(f"\n所有任务完成,总耗时: {end_time - start_time:.2f} 秒")
    print("结果:", results)

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

这段代码里,

fetch_data
是一个协程函数,它用
await asyncio.sleep(delay)
来模拟耗时的I/O操作。注意,这里用的是
asyncio.sleep
而不是
time.sleep
,因为后者会阻塞整个程序,彻底违背了异步的初衷。
main
函数则通过
asyncio.gather
同时启动了三个
fetch_data
协程。你会发现,虽然每个任务都有自己的延迟,但总耗时却约等于最长的那个任务的耗时,而不是它们的总和。这就是
asyncio
带来的并发效果,程序在等待一个任务时,并没有闲着,而是去处理了另一个任务。

深入理解asyncio:协程、事件循环与任务的运作机制是什么?

当我们谈论

asyncio
时,避不开的三个核心概念就是协程(Coroutines)、事件循环(Event Loop)和任务(Tasks)。它们共同构成了异步编程的骨架。

首先,协程。简单来说,任何用

async def
定义的函数都是一个协程函数。调用它并不会立即执行,而是返回一个协程对象。这个对象本身是惰性的,需要被“调度”才能运行。协程最关键的特性是它可以在执行过程中通过
await
关键字“暂停”自己,把控制权交还给调度器,等待某个异步操作完成,完成后再从暂停的地方“恢复”执行。这种暂停和恢复是协作式的,意味着协程自己决定何时让出控制权,而不是被操作系统强制中断。

其次,事件循环。你可以把它想象成

asyncio
应用程序的心脏。它是一个无限循环,负责监听和分发事件(比如网络数据到达、定时器到期等),并调度那些准备好执行的协程。当一个协程通过
await
暂停时,它会告诉事件循环“我需要等待某个东西,你先去忙别的吧”。事件循环就会去检查有没有其他准备好运行的协程,或者有没有新的事件发生。一旦协程等待的事件发生,事件循环就会重新唤醒它,让它继续执行。整个异步程序的并发性,都依赖于事件循环的有效调度。

最后,任务。协程对象本身并不能直接被事件循环运行,它需要被封装成一个

Task
对象。
asyncio.create_task()
就是用来做这个的,它将一个协程包装成一个
Task
,并安排它在事件循环中运行。
Task
Future
的子类,它代表了一个即将完成的异步操作,你可以
await
一个
Task
来等待它的结果。当我们需要并发运行多个协程时,通常会创建多个
Task
,然后用
asyncio.gather()
或单独
await
它们来收集结果。
Task
的存在,让事件循环能够更方便地管理和调度多个并发的协程,它就像是协程在事件循环中的“执行代理”。

理解这三者之间的关系至关重要:你写下协程(

async def
),事件循环负责调度这些协程,而任务(
Task
)则是协程在事件循环中被调度和管理时的表现形式。

编写高效异步I/O代码时,常见的陷阱与优化策略有哪些?

尽管

asyncio
带来了巨大的性能潜力,但在实际开发中,如果不注意一些细节,很容易掉进“坑”里,反而达不到预期的效果。

一个最常见的陷阱就是混用阻塞式调用。如果你的协程函数内部不小心调用了

time.sleep()
requests.get()
(同步HTTP库)或者其他任何会阻塞当前线程的同步I/O操作,那么整个事件循环都会被卡住,所有其他异步任务都将无法执行,你的程序就退化成了同步的。解决方案是,始终使用
asyncio
提供的异步版本(如
asyncio.sleep
),或者专门为异步设计的库(如
aiohttp
asyncpg
),对于那些没有异步版本的CPU密集型或阻塞I/O操作,可以考虑使用
loop.run_in_executor()
将其放到单独的线程或进程池中执行,避免阻塞主事件循环。

另一个容易被忽视的问题是忘记

await
。当你调用一个
async def
函数时,它返回的是一个协程对象,而不是执行结果。如果你忘记了
await
它,这个协程就不会被调度执行,它就像一个被创建出来但从未启动的汽车。通常Python解释器会给出
RuntimeWarning: coroutine '...' was never awaited
的警告,但这很容易被忽略。务必确保所有需要执行的协程都被
await
了,或者通过
asyncio.create_task()
显式地安排到事件循环中。

ShopEx助理
ShopEx助理

一个类似淘宝助理、ebay助理的客户端程序,用来方便的在本地处理商店数据,并能够在本地商店、网上商店和第三方平台之间实现数据上传下载功能的工具。功能说明如下:1.连接本地商店:您可以使用ShopEx助理连接一个本地安装的商店系统,这样就可以使用助理对本地商店的商品数据进行编辑等操作,并且数据也将存放在本地商店数据库中。默认是选择“本地未安装商店”,本地还未安

下载

在优化方面,并发执行独立任务是首要策略。如果你的程序需要同时发起多个独立的网络请求或数据库查询,使用

asyncio.gather(*coroutines)
是最高效的方式。它会等待所有传入的协程都完成后,以列表的形式返回它们的结果,并且总耗时由最长的那个协程决定。这比一个个
await
要快得多。

对于需要与外部服务交互的应用,连接池管理是提升效率的关键。无论是HTTP客户端(如

aiohttp.ClientSession
)还是数据库连接(如
asyncpg
),创建和销毁连接都是有开销的。使用连接池可以复用已有的连接,减少握手时间,显著提升性能。确保你的异步客户端库支持连接池,并正确配置和使用它们。

最后,资源管理。异步代码中,打开文件、网络连接等资源后,同样需要确保它们被正确关闭,即使发生异常。

async with
语句就是为此而生。它类似于同步的
with
语句,可以确保异步上下文管理器(比如
aiohttp.ClientSession
)在代码块结束时被正确进入和退出,即使有异常发生,资源也能得到妥善处理。这大大简化了资源管理,避免了资源泄露。

如何调试和测试基于asyncio的异步应用?

调试和测试异步代码,尤其是像

asyncio
这种基于事件循环的并发模型,会比同步代码复杂一些,但也有其特定的工具和方法。

调试方面,

asyncio
提供了一个内置的调试模式。你可以在运行Python脚本时加上
-m asyncio
参数(例如
python -m asyncio your_script.py
),或者在代码中通过
loop.set_debug(True)
来启用。调试模式会提供更多关于协程状态、任务切换以及潜在问题的详细信息,比如哪些协程被阻塞了,或者哪些协程没有被
await
。这对于找出那些“被遗忘”的协程或者性能瓶颈非常有帮助。此外,标准的Python
logging
模块在异步代码中依然有效,合理地在关键路径上添加日志输出,可以帮助你追踪事件流和任务的生命周期。当任务变得复杂时,
asyncio.all_tasks()
可以让你看到当前事件循环中所有正在运行或等待的任务,这对于理解程序当前的状态非常有帮助。

更进一步的调试,可能会涉及到断点和单步执行。现代IDE(如VS Code、PyCharm)通常都对

asyncio
代码有良好的支持,你可以在协程内部设置断点,然后像调试同步代码一样单步执行。理解
await
关键字的工作原理至关重要:当执行到
await
时,当前协程会暂停,控制权交还给事件循环,断点会跳到下一个被事件循环调度的任务。当之前
await
的异步操作完成后,事件循环会重新调度回这个协程,断点会从
await
的下一行继续执行。

至于测试

pytest-asyncio
是一个非常强大的Pytest插件,它极大地简化了
asyncio
应用的测试。它允许你直接编写
async def
的测试函数,并且会自动管理事件循环,确保每个测试都在一个干净的事件循环中运行。

import pytest
import asyncio

async def async_add(a, b):
    await asyncio.sleep(0.01) # 模拟异步操作
    return a + b

@pytest.mark.asyncio
async def test_async_add():
    result = await async_add(1, 2)
    assert result == 3

async def mock_network_call():
    # 模拟一个会失败的网络请求
    raise ConnectionError("Failed to connect")

@pytest.mark.asyncio
async def test_network_failure():
    with pytest.raises(ConnectionError):
        await mock_network_call()

上面的例子展示了如何使用

pytest-asyncio
来测试异步函数。
@pytest.mark.asyncio
装饰器是关键,它告诉Pytest这是一个异步测试,需要特殊处理。

在测试异步代码时,模拟(Mocking)也是不可或缺的。你经常需要模拟外部服务(数据库、API)的异步响应,以确保你的业务逻辑在不同场景下都能正确工作。可以使用

unittest.mock
库结合
AsyncMock
(Python 3.8+)或者
MagicMock
来模拟异步函数和方法。例如,你可以模拟一个异步数据库查询,让它返回预设的数据,而不是真的去连接数据库。

最后,要考虑到并发场景下的测试。虽然

asyncio
是单线程的,但其并发特性可能导致一些难以复现的竞态条件或时序问题。编写一些测试来模拟高并发或特定时序的场景,尽管这很难做到穷举,但可以帮助你发现一些潜在的bug。例如,测试当多个任务同时尝试修改共享状态时,是否会产生错误结果。这通常需要更精巧的设计和对
asyncio.Lock
asyncio.Semaphore
等同步原语的运用。

相关文章

编程速学教程(入门课程)
编程速学教程(入门课程)

编程怎么学习?编程怎么入门?编程在哪学?编程怎么学才快?不用担心,这里为大家提供了编程速学教程(入门课程),有需要的小伙伴保存下载就能学习啦!

下载

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

相关专题

更多
python开发工具
python开发工具

php中文网为大家提供各种python开发工具,好的开发工具,可帮助开发者攻克编程学习中的基础障碍,理解每一行源代码在程序执行时在计算机中的过程。php中文网还为大家带来python相关课程以及相关文章等内容,供大家免费下载使用。

769

2023.06.15

python打包成可执行文件
python打包成可执行文件

本专题为大家带来python打包成可执行文件相关的文章,大家可以免费的下载体验。

661

2023.07.20

python能做什么
python能做什么

python能做的有:可用于开发基于控制台的应用程序、多媒体部分开发、用于开发基于Web的应用程序、使用python处理数据、系统编程等等。本专题为大家提供python相关的各种文章、以及下载和课程。

764

2023.07.25

format在python中的用法
format在python中的用法

Python中的format是一种字符串格式化方法,用于将变量或值插入到字符串中的占位符位置。通过format方法,我们可以动态地构建字符串,使其包含不同值。php中文网给大家带来了相关的教程以及文章,欢迎大家前来阅读学习。

659

2023.07.31

python教程
python教程

Python已成为一门网红语言,即使是在非编程开发者当中,也掀起了一股学习的热潮。本专题为大家带来python教程的相关文章,大家可以免费体验学习。

1345

2023.08.03

python环境变量的配置
python环境变量的配置

Python是一种流行的编程语言,被广泛用于软件开发、数据分析和科学计算等领域。在安装Python之后,我们需要配置环境变量,以便在任何位置都能够访问Python的可执行文件。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

549

2023.08.04

python eval
python eval

eval函数是Python中一个非常强大的函数,它可以将字符串作为Python代码进行执行,实现动态编程的效果。然而,由于其潜在的安全风险和性能问题,需要谨慎使用。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

579

2023.08.04

scratch和python区别
scratch和python区别

scratch和python的区别:1、scratch是一种专为初学者设计的图形化编程语言,python是一种文本编程语言;2、scratch使用的是基于积木的编程语法,python采用更加传统的文本编程语法等等。本专题为大家提供scratch和python相关的文章、下载、课程内容,供大家免费下载体验。

730

2023.08.11

html编辑相关教程合集
html编辑相关教程合集

本专题整合了html编辑相关教程合集,阅读专题下面的文章了解更多详细内容。

16

2026.01.21

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

相关下载

更多

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
最新Python教程 从入门到精通
最新Python教程 从入门到精通

共4课时 | 11.6万人学习

Django 教程
Django 教程

共28课时 | 3.3万人学习

SciPy 教程
SciPy 教程

共10课时 | 1.2万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号