Python 异步编程介绍与代码示例

Python 异步编程介绍与代码示例

一、异步编程概述

异步编程是一种编程范式，它旨在处理那些需要等待I/O操作完成或执行耗时任务的情况。在传统的同步编程中，代码会按照顺序逐行执行，直到遇到一个耗时操作，它会阻塞程序的执行直到该操作完成。这种阻塞式的模型在某些场景下效率低下，因为代码在等待操作完成时无法执行其他任务。异步编程通过非阻塞I/O和协程（coroutine）来提高效率，使得程序在等待某些操作时能够继续执行其他任务，从而提高程序的并发性和响应性。

二、Python 异步编程基础

Python 从 3.4 版本开始引入了 asyncio 库，为异步编程提供了丰富的支持。asyncio 库包括了协程、事件循环（event loop）、任务（task）和期物（future）等关键概念。

  1. 协程（Coroutine）：
    协程是一种特殊的函数，可以在执行过程中暂停和恢复。在 Python 中，协程是通过在函数定义前加上 async 关键字来创建的。协程内部可以使用 await 关键字来暂停自身的执行，等待其他协程或异步操作完成。

  2. 事件循环（Event Loop）：
    事件循环是异步编程的核心，它负责调度和执行协程，确保它们按照正确的顺序执行。在 Python 中，asyncio 模块提供了事件循环的实现，开发者可以通过 asyncio.get_event_loop() 获取默认的事件循环对象，并使用它来运行协程。

  3. 任务（Task）：
    任务是 asyncio 库中的一个基本概念，它表示一个异步操作。任务可以通过调用 asyncio.create_task() 函数来创建，并返回一个 Task 对象。Task 对象本质上是一个特殊的 Future 对象，它封装了协程的执行。

  4. 期物（Future）：
    期物用于承载协程的执行结果。当协程开始执行时，会创建一个 Future 对象与之关联。协程执行完成后，其结果会被存储在 Future 对象中。开发者可以通过 await 关键字等待 Future 对象的结果。

三、async/await 语法

从 Python 3.5 版本开始，可以使用 async 和 await 关键字来编写异步代码。async 关键字用于定义一个协程函数，而 await 关键字用于在协程中暂停执行，等待其他协程或异步操作完成。

示例 1：简单的异步函数
import asyncio

async def my_coroutine():
    print("Coroutine started")
    await asyncio.sleep(1)  # 模拟异步操作
    print("Coroutine resumed")
    return "Result"

async def main():
    result = await my_coroutine()
    print(f"Result: {result}")

asyncio.run(main())

在这个示例中，my_coroutine 是一个协程函数，它使用 await asyncio.sleep(1) 来模拟一个耗时操作。main 函数也是一个协程函数，它使用 await 关键字等待 my_coroutine 的执行结果。最后，通过 asyncio.run(main()) 启动事件循环，并运行 main 协程。

示例 2：并发执行多个异步任务
import asyncio

async def task(name, delay):
    print(f"Executing task: {name}")
    await asyncio.sleep(delay)
    print(f"Task {name} finished")

async def main():
    tasks = [task("Task 1", 2), task("Task 2", 1), task("Task 3", 3)]
    await asyncio.gather(*tasks)

asyncio.run(main())

在这个示例中，我们定义了三个异步任务 task，每个任务都有一个名称和延迟时间。在 main 函数中，我们使用 asyncio.gather(*tasks) 来并发执行这些任务。asyncio.gather 会等待所有传入的协程或任务完成，并返回一个包含所有结果的列表。

四、异步编程的优势

  1. 提高程序效率：
    异步编程通过非阻塞I/O和并发执行多个任务，减少了程序在等待操作完成时的空闲时间，从而提高了程序的执行效率。

  2. 提高程序响应性：
    在Web服务器、数据库连接等场景中，异步编程能够更快地响应客户端的请求，提升用户体验。

  3. 简化复杂逻辑：
    异步编程通过协程和事件循环等机制，使得处理复杂逻辑（如回调地狱）变得更加简单和直观。

五、异步编程的注意事项

在进行Python异步编程时，需要注意以下几个方面，以确保代码的正确性、效率和可维护性：

  1. 避免阻塞操作：
    异步编程的核心优势在于非阻塞I/O，因此应尽量避免在协程中执行阻塞操作。如果必须执行阻塞操作，可以通过asyncio.run_in_executor()方法将其封装在executor中执行，从而避免阻塞事件循环。

  2. 异常处理：
    异步编程中的异常处理需要格外小心。由于异步操作可能在将来的某个时间点完成，因此应使用try-except语句来捕获和处理可能的异常。此外，asyncio还提供了asyncio.ensure_future()函数，可以将协程封装为Future对象，从而更方便地处理异常。

  3. 并发度控制：
    通过控制并发度，可以平衡程序的性能和资源消耗。如果并发任务过多，可能会导致资源耗尽或性能下降。可以使用asyncio.Semaphore等同步原语来限制同时执行的任务数量，从而避免这种情况的发生。

  4. 共享资源访问：
    在异步编程中，多个协程可能会同时访问共享资源，这可能导致数据竞争和状态不一致的问题。为了避免这种情况，应使用适当的同步机制（如锁、信号量等）来保护共享资源。

  5. 事件循环的管理：
    在Python的异步编程中，事件循环是核心组件。它负责调度和执行协程，以及处理I/O和系统事件。通常，应使用asyncio.run()函数来启动和管理事件循环，因为它会自动创建事件循环、运行协程并关闭事件循环。除非有特定需求，否则应避免手动创建和管理事件循环。

  6. 协程的调度和取消：
    在复杂的异步程序中，可能需要动态地调度和取消协程。asyncio提供了asyncio.create_task()函数来创建任务（即协程的封装），并提供了任务对象的方法来检查任务状态、取消任务等。

  7. 调试和日志记录：
    异步编程的调试可能比同步编程更复杂，因为程序的执行流程是非线性的。因此，应使用适当的调试工具和日志记录来跟踪程序的执行和定位问题。

  8. 第三方库和框架的兼容性：
    在使用异步编程时，可能会遇到与第三方库和框架的兼容性问题。一些库可能不支持异步操作，或者它们的异步API不够完善。在这种情况下，需要仔细评估是否可以使用这些库，或者寻找替代方案。

  9. 性能优化：
    异步编程虽然可以提高程序的并发性和响应性，但也可能引入额外的性能开销。例如，过多的上下文切换和锁竞争都可能导致性能下降。因此，在进行异步编程时，应注意性能优化，避免不必要的开销。

  10. 代码的可读性和可维护性：
    异步代码的可读性和可维护性通常比同步代码更差，因为异步逻辑更复杂且更难跟踪。因此，在编写异步代码时，应注意代码的清晰性和结构性，避免过度复杂和难以理解的代码。

通过遵循上述注意事项，可以更有效地利用Python的异步编程能力，编写出高效、可靠和可维护的异步应用程序。

六、异步编程中的错误处理

在异步编程中，错误处理是一个重要的方面。由于异步操作可能在将来的某个时间点完成，并且可能成功或失败，因此我们需要一种机制来捕获和处理这些错误。

示例 3：异步错误处理
import asyncio

async def risky_operation():
    # 假设这是一个可能引发异常的异步操作
    await asyncio.sleep(1)
    raise ValueError("Something went wrong!")

async def main():
    try:
        await risky_operation()
    except ValueError as e:
        print(f"Caught an exception: {e}")

asyncio.run(main())

在这个示例中，risky_operation 是一个可能抛出异常的异步函数。在 main 函数中，我们使用 try-except 块来捕获并处理这个异常。

七、异步上下文管理器

在 Python 中，上下文管理器（通过 with 语句使用）常用于资源管理，如文件操作、数据库连接等。在异步编程中，我们也有异步上下文管理器的需求。

从 Python 3.7 开始，asyncio 库引入了 async with 语法，允许我们使用异步上下文管理器。

示例 4：异步上下文管理器
import asyncio

class AsyncContextManager:
    async def __aenter__(self):
        print("Entering context")
        # 初始化代码，如打开数据库连接
        return self

    async def __aexit__(self, exc_type, exc_val, exc_tb):
        print("Exiting context")
        # 清理代码，如关闭数据库连接
        return False  # 如果需要抑制异常，则返回 True

async def main():
    async with AsyncContextManager():
        print("Inside the context")
        await asyncio.sleep(1)

asyncio.run(main())

在这个示例中，AsyncContextManager 类定义了异步上下文管理器的行为。__aenter__ 方法在进入上下文时执行，__aexit__ 方法在退出上下文时执行。注意，__aexit__ 方法必须返回一个布尔值，用于指示是否需要抑制异常。

八、异步编程与并发

虽然异步编程和并发编程经常一起讨论，但它们并不完全相同。异步编程主要关注于单个线程内的非阻塞操作，而并发编程则涉及多个线程或进程同时执行多个任务。然而，在 Python 的 asyncio 库中，我们可以通过异步编程实现并发效果，因为事件循环能够同时调度多个协程的执行。

九、高级话题：异步生成器

Python 3.6 引入了异步生成器（async generators），它们是结合了异步编程和生成器特性的强大工具。异步生成器允许你编写一个可以异步产生值的函数，这些值可以在需要时逐个获取，而无需一次性加载到内存中。

示例 5：异步生成器
import asyncio

async def async_generator():
    for i in range(5):
        await asyncio.sleep(1)  # 模拟异步操作
        yield i

async def main():
    async for value in async_generator():
        print(value)

asyncio.run(main())

在这个示例中，async_generator 是一个异步生成器函数，它使用 yield 关键字来异步产生值。在 main 函数中，我们使用 async for 循环来逐个获取这些值。

十、总结

Python 的异步编程通过 asyncio 库提供了强大的支持，使得编写高效、响应迅速的异步应用程序成为可能。通过协程、事件循环、任务和期物等概念，Python 的异步编程模型能够处理复杂的异步逻辑，并优化程序的执行效率。然而，异步编程也带来了一些挑战，如错误处理和并发控制等。通过深入学习这些概念，并结合实际的应用场景，我们可以更好地利用 Python 的异步编程能力来构建高效、可靠的应用程序。

以上就是对 Python 异步编程的一个基本介绍和代码示例。希望这些信息能够帮助你理解并掌握 Python 的异步编程技术。

在这里插入图片描述

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：/a/779197.html

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

测试人应该懂的！自动化测试必会之数据驱动测试

测试人应该懂的！自动化测试必会之数据驱动测试

数据驱动测试 在实际的测试过程中，我们会发现好几组用例都是相同的操作步骤，只是测试数据的不同，而我们往往需要编写多次用例来进行测试，此时我们可以利用数据驱动测试来简化该种操作。 参数化： 输入数据的不同从而产…
阅读更多...
【云计算】公有云、私有云、混合云、社区云、多云

【云计算】公有云、私有云、混合云、社区云、多云

公有云、私有云、混合云、社区云、多云 1.云计算的形态1.1 公有云1.2 私有云1.3 混合云1.4 社区云1.5 多云1.5.1 多云和混合云之间的关系1.5.2 多云的用途1.5.3 影子 IT 和多云1.5.4 优缺点 2.不同云形态的对比 1.云计算的形态 张三⾃⼰在家做饭吃，这是 私有云&…
阅读更多...
非堆成加密是公私钥使用

非堆成加密是公私钥使用

对称加密学习-CSDN博客 加密算法学习-CSDN博客 非对称加密算法使用一对密钥，包括一个公钥和一个私钥，它们是数学上相关联的，但公钥可以公开分享，而私钥必须保密。以下是使用非对称加密算法的一般步骤： 密钥生成&…
阅读更多...
Spring相关面试题（四）

Spring相关面试题（四）

49 JavaConfig方式如何启用AOP?如何强制使用cglib？ 在JavaConfig类，加上EnableAspectJAutoProxy 如果要强制使用CGLIB动态代理 ，加上(proxyTargetClass true) 加上(exposeProxy true) 就是将对象暴露到线程池中。 50 介绍AOP在Spring中…
阅读更多...
打开浏览器控制台，点击应用，浏览器崩溃

打开浏览器控制台，点击应用，浏览器崩溃

调试的时候，打开控制台，点击 “应用” 立马浏览器奔溃，但是点击别的没问题 调查发现是因为manifest.json这个文件引起的 manifest.json 最主要的原因是因为没有设置这个sizes字段 Google浏览器更新大概到126之后的版本会有问题，之…
阅读更多...
关于CPU你一定要注意的重要参数，警惕韭菜陷阱

关于CPU你一定要注意的重要参数，警惕韭菜陷阱

昨天遇到个奇葩事，有个粉丝喷我“懂不懂什么叫I9？”言下之意就是CPU中I9>i7>I5>I3，我也不知道咋说，只是提醒大家小心被坑，花了多的钱用的差的性能。作为回应，仅以此篇说下CPU咱们臭打游戏一定要知…
阅读更多...
新手学Cocos报错 [Assets] Failed to open

新手学Cocos报错 [Assets] Failed to open

两个都在偏好设置里面调（文件下面的偏好设置）： 1.设置中文？ 2.报错 [Assets] Failed to open？ 这样在点击打开ts文件的时候就不会报错，并且用vscode编辑器打开了， 同样也可以改成你们自己喜欢…
阅读更多...
彻底解决Path with “WEB-INF“ or “META-INF“: [WEB-INF/views/index.jsp]

彻底解决Path with “WEB-INF“ or “META-INF“: [WEB-INF/views/index.jsp]

背景描述 项目使用的是springboot2jsp的架构。以前好好的项目复制了一份，然后就无法访问报错。百度了好久都乱七八糟的，还没有解决问题。错误消息如下： 2024-07-05 15:45:51.335 INFO [http-nio-12581-exec-1]org.springframework.web.ser…
阅读更多...
【Selenium配置】WebDriver安装浏览器驱动（ChromeEdge）

【Selenium配置】WebDriver安装浏览器驱动（ChromeEdge）

【Selenium配置】WebDriver安装浏览器驱动（Chrome&Edge） 文章目录 【Selenium配置】WebDriver安装浏览器驱动（Chrome&Edge）Chrome确认Chrome版本下载对应driver把解压后的chromedriver文件放在chrome安装目录下&#xff0…
阅读更多...
字节跳动与南开联合开源 StoryDiffusion：一键生成漫画和视频故事的神器！完全免费！

字节跳动与南开联合开源 StoryDiffusion：一键生成漫画和视频故事的神器！完全免费！

大家好，我是程序员X小鹿，前互联网大厂程序员，自由职业2年，也一名 AIGC 爱好者，持续分享更多前沿的「AI 工具」和「AI副业玩法」，欢迎一起交流~ 漫画，是多少人童年的回忆啊！ 记得小学…
阅读更多...
VMware安装centos9详细教程(保姆级)

VMware安装centos9详细教程(保姆级)

前言 centos9最新的centos版本，在近期的使用中发现它的操作界面与以往的centos7/8更加舒适，界面优化更加精细 项目终止日期（EOL） 从公告可知，CentOS 项目重心从 CentOS Linux 转移到了 CentOS Stream。下面是各个项…
阅读更多...
初识STM32：开发方式及环境

初识STM32：开发方式及环境

STM32的编程模型 假如使用C语言的方式写了一段程序，这段程序首先会被烧录到芯片当中（Flash存储器中），Flash存储器中的程序会逐条的进入CPU里面去执行。 CPU相当于人的一个大脑，虽然能执行运算和执行指令，…
阅读更多...
沪上繁花：上海电信的5G-A之跃

沪上繁花：上海电信的5G-A之跃

2024年6月18日下午，在上海举行的3GPP RAN第104次会议上，3GPP正式宣布R18标准冻结。R18是无线网络面向5G-A的第一个版本，其成功冻结正式宣布了5G发展迎来新机遇，5G-A商用已进入全新的发展阶段。 在5G-A滚滚而来的时代洪流中&#x…
阅读更多...
基于STM32的通用红外遥控器设计: 解码、学习与发射（代码示例）

基于STM32的通用红外遥控器设计: 解码、学习与发射（代码示例）

摘要： 本文将带你使用STM32打造一款功能强大的万能红外遥控器，它可以学习和复制多种红外信号，并通过OLED屏幕和按键实现便捷操作。我们将深入探讨红外通信原理、STM32编程、OLED显示和EEPROM数据存储等关键技术，并提供完整的代码示…
阅读更多...
【Linux进阶】文件系统7——文件系统简单操作

【Linux进阶】文件系统7——文件系统简单操作

1.磁盘与目录的容量 现在我们知道磁盘的整体数据是在超级区块中，但是每个文件的容量则在inode 当中记载。 那在命令行模式下面该如何显示这几个数据？下面就让我们来谈一谈这两个命令： df：列出文件系统的整体磁盘使用量&#xf…
阅读更多...
（阿里云在线播放）基于SpringBoot+Vue前后端分离的在线教育平台项目

（阿里云在线播放）基于SpringBoot+Vue前后端分离的在线教育平台项目

💗博主介绍💗：✌在职Java研发工程师、专注于程序设计、源码分享、技术交流、专注于Java技术领域和毕业设计✌ 温馨提示：文末有 CSDN 平台官方提供的老师 Wechat / QQ 名片 :) Java精品实战案例《700套》 2025最新毕业设计选题推荐…
阅读更多...
公务员考试、事业编考试、教师资格证、面试、K12资料、电子书

公务员考试、事业编考试、教师资格证、面试、K12资料、电子书

点击上方△腾阳 关注 作者 l 腾阳 转载请联系授权 你好，我是腾阳。 在这个自媒体的海洋里，我曾是一只迷失方向的小鸟，多次尝试飞翔却总是跌跌撞撞。 但每一次跌倒，都让我更坚定地相信，只要不放弃，总…
阅读更多...
【Android】自定义换肤框架01之皮肤包制作

【Android】自定义换肤框架01之皮肤包制作

前言 目前为止，市面上主流的安卓换肤方案，其实原理都是差不多的 虽然大多都号称一行代码集成，但其实想要做到完全适配，并不简单 这个系列，就是让大家从零开始，完全掌握这方面知识，这样才能对…
阅读更多...
Floyd

Floyd

模板&#xff1a; 时间复杂度&#xff1a;O( ) memset(v,127,sizeof(v));for(int k1;k<n;k)for(int i1;i<n;i)for(int j1;j<n;j)if(v[i][k]<1<<30&&v[k][j]<1<<30)v[i][j]min(v[i][j],v[i][k]v[k][j]);
阅读更多...
2024年软件测试八股文（含答案）

2024年软件测试八股文（含答案）

Part1 1、你的测试职业发展是什么&#xff1f; 测试经验越多&#xff0c;测试能力越高。所以我的职业发展是需要时间积累的&#xff0c;一步步向着高级测试工程师奔去。而且我也有初步的职业规划&#xff0c;前3年积累测试经验&#xff0c;按如何做好测试工程师的要点去要求自…
阅读更多...
最新文章

Copyright @ 2022~2023