- 当前位置：首页 >域名 >Python中的异步编程：Asyncio
Python中的异步编程：Asyncio
发布时间：2025-11-05 12:17:41 来源：创站工坊 作者：应用开发
如果你已经决定要理解 Python 的异步异步部分，欢迎来到我们的编程“Asyncio How-to ”。
注：哪怕连异动范式的异步存在都不知道的情况下，你也可以成功地使用 Python。编程但是异步，如果你对底层运行模式感兴趣的编程话，asyncio 绝对值得查看。异步
异步是编程怎么一回事?
在传统的顺序编程中， 所有发送给解释器的异步指令会一条条被执行。此类代码的编程输出容易显现和预测。 但是异步…
譬如说你有一个脚本向3个不同服务器请求数据。 有时，编程谁知什么原因，异步发送给其中一个服务器的编程请求可能意外地执行了很长时间。想象一下从第二个服务器获取数据用了10秒钟。异步在你等待的时候，整个脚本实际上什么也没干。如果你可以写一个脚本可以不去等待第二个请求而是仅仅跳过它，然后开始执行第三个请求，然后回到第二个请求，云服务器执行之前离开的位置会怎么样呢。就是这样。你通过切换任务最小化了空转时间。尽管如此，当你需要一个几乎没有I/O的简单脚本时，你不想用异步代码。
还有一件重要的事情要提，所有代码在一个线程中运行。所以如果你想让程序的一部分在后台执行同时干一些其他事情，那是不可能的。
准备开始
这是 asyncio 主概念最基本的定义:
协程 — 消费数据的生成器，但是不生成数据。Python 2.5 介绍了一种新的语法让发送数据到生成器成为可能。我推荐查阅David Beazley “A Curious Course on Coroutines and Concurrency” 关于协程的详细介绍。 任务 — 协程调度器。如果你观察下面的代码，你会发现它只是让 event_loop 尽快调用它的_step ，企商汇同时 _step 只是调用协程的下一步。 class Task(futures.Future): def __init__(self, coro, loop=None): super().__init__(loop=loop) ... self._loop.call_soon(self._step) def _step(self): ... try: ... result = next(self._coro) except StopIteration as exc: self.set_result(exc.value) except BaseException as exc: self.set_exception(exc) raise else: ... self._loop.call_soon(self._step) 事件循环 — 把它想成 asyncio 的中心执行器。现在我们看一下所有这些如何融为一体。正如我之前提到的，异步代码在一个线程中运行。
从上图可知：
1.消息循环是在线程中执行
2.从队列中取得任务
3.每个任务在协程中执行下一步动作
4.如果在一个协程中调用另一个协程(await <coroutine_name>)，会触发上下文切换，挂起当前协程，并保存现场环境(变量，状态)，然后载入被调用协程
5.如果协程的执行到阻塞部分(阻塞I/O，Sleep)，当前协程会挂起，并将控制权返回到线程的消息循环中，然后消息循环继续从队列中执行下一个任务...以此类推
6.队列中的所有任务执行完毕后，消息循环返回***个任务
异步和同步的代码对比
现在我们实际验证异步模式的切实有效，我会比较两段 python 脚本，这两个脚本除了sleep 方法外，其余部分完全相同。在***个脚本里，我会用标准的 time.sleep 方法，在第二个脚本里使用 asyncio.sleep 的WordPress模板异步方法。
这里使用 Sleep 是因为它是一个用来展示异步方法如何操作 I/O 的最简单办法。
使用同步 sleep 方法的代码：
import asyncio import time from datetime import datetime async def custom_sleep(): print(SLEEP, datetime.now()) time.sleep(1) async def factorial(name, number): f = 1 for i in range(2, number+1): print(Task {}: Compute factorial({}).format(name, i)) await custom_sleep() f *= i print(Task {}: factorial({}) is {}\n.format(name, number, f)) start = time.time() loop = asyncio.get_event_loop() tasks = [ asyncio.ensure_future(factorial("A", 3)), asyncio.ensure_future(factorial("B", 4)), ] loop.run_until_complete(asyncio.wait(tasks)) loop.close() end = time.time() print("Total time: {}".format(end - start))脚本输出：
Task A: Compute factorial(2) SLEEP 2017-04-06 13:39:56.207479 Task A: Compute factorial(3) SLEEP 2017-04-06 13:39:57.210128 Task A: factorial(3) is 6 Task B: Compute factorial(2) SLEEP 2017-04-06 13:39:58.210778 Task B: Compute factorial(3) SLEEP 2017-04-06 13:39:59.212510 Task B: Compute factorial(4) SLEEP 2017-04-06 13:40:00.217308 Task B: factorial(4) is 24 Total time: 5.016386032104492使用异步 Sleep 的代码：
import asyncio import time from datetime import datetime async def custom_sleep(): print(SLEEP {}\n.format(datetime.now())) await asyncio.sleep(1) async def factorial(name, number): f = 1 for i in range(2, number+1): print(Task {}: Compute factorial({}).format(name, i)) await custom_sleep() f *= i print(Task {}: factorial({}) is {}\n.format(name, number, f)) start = time.time() loop = asyncio.get_event_loop() tasks = [ asyncio.ensure_future(factorial("A", 3)), asyncio.ensure_future(factorial("B", 4)), ] loop.run_until_complete(asyncio.wait(tasks)) loop.close() end = time.time() print("Total time: {}".format(end - start))脚本输出：
Task A: Compute factorial(2) SLEEP 2017-04-06 13:44:40.648665 Task B: Compute factorial(2) SLEEP 2017-04-06 13:44:40.648859 Task A: Compute factorial(3) SLEEP 2017-04-06 13:44:41.649564 Task B: Compute factorial(3) SLEEP 2017-04-06 13:44:41.649943 Task A: factorial(3) is 6 Task B: Compute factorial(4) SLEEP 2017-04-06 13:44:42.651755 Task B: factorial(4) is 24 Total time: 3.008226156234741从输出可以看到，异步模式的代码执行速度快了大概两秒。当使用异步模式的时候(每次调用 await asyncio.sleep(1) )，进程控制权会返回到主程序的消息循环里，并开始运行队列的其他任务(任务A或者任务B)。
当使用标准的 sleep方法时，当前线程会挂起等待。什么也不会做。实际上，标准的 sleep 过程中，当前线程也会返回一个 python 的解释器，可以操作现有的其他线程，但这是另一个话题了。
推荐使用异步模式编程的几个理由
很多公司的产品都广泛的使用了异步模式，如 Facebook 旗下著名的 React Native 和 RocksDB 。像 Twitter 每天可以承载 50 亿的用户访问，靠的也是异步模式编程。所以说,通过代码重构，或者改变模式方法，就能让系统工作的更快，为什么不去试一下呢?
- 上一篇：如何更改台式电脑密码（详细教程带你轻松更改密码）
- 下一篇：个人平常经常用到 TeamViewer，TeamViewer 10 发布之后提供了显著的性能优化，还同时提高了语音传输质量、优化了登录时间及提高多核处理器的处理能力。现在将在 Ubuntu 15.10 中安装 TeamViewer 10 的步骤记录说明一下，有兴趣的朋友也可以试用。Ubuntu 15.10中安装TeamViewer 10安装过程非常简单，大家按如下步骤操作即可：1.使用终端下载安装程序(32位和64位Ubuntu通用)复制代码代码如下:sudo dpkg -i teamviewer_i386.deb 3.使用如下命令处理依赖问题复制代码代码如下:sudo apt-get install –f 安装好之后就可以直接使用啦！跟 Windows 版本界面都差不多。以上就是Ubuntu 15.10中安装TeamViewer 10的简单介绍，希望对大家的学习有所帮助。
- 比较苹果和三星处理器的性能和特点（探索苹果和三星处理器的差异与优势）
- vivo夜拍效果的惊艳表现（vivo手机夜间拍摄能力全面升级，图像更清晰细腻）
- 2015魅族手机综合评测（探索魅族手机的卓越性能与创新设计）
- 以核芯显卡的优势和性能评测（解读Intel核芯显卡的强大表现及市场竞争力）
- 电脑错误代码（掌握关键错误代码，轻松解决电脑问题）
- 2016神舟笔记本（性能强悍，质量可靠，给你畅快的使用体验）
- 以恩杰大幻影（探索传奇幕后故事，恩杰大幻影的魅力与创意）
- 三星A7100拍照表现如何？（探索三星A7100摄像头的品质和功能）
- 解决电脑双击提示错误的方法（如何修复电脑双击无法打开文件或文件夹的问题）
- dfyou智能手环（探索dfyou智能手环的卓越功能和用户体验）
- 电脑主板安装讲解教程（详细指导如何安装电脑主板）
- 4G飞享套餐68元，实惠流量畅享（全面升级，让你爱不释手）
- 以基因美因为主题的文章（探讨基因美因在社会中的影响力及未来发展趋势）
- 三星微单NX300的功能与特点（体验三星微单NX300的高画质与便携性）
- 使用启动U盘还原系统教程（详细步骤帮助您轻松还原系统）
- 罗技G302（高性能，低价格，满足你的游戏需求）
- 索尼A35相机评测（探索索尼A35的优势与劣势）
- 华强LED（以高质量和创新为导向，华强LED引领行业发展）
- 解读求精电脑平车错误代码及排除故障方法（深入分析求精电脑平车错误代码，解决常见故障问题）
- 360N4S音质评测——打造震撼音乐体验（揭秘360N4S的音效巅峰与细节呈现）
随便看看
- Copyright © 2025 Powered by Python中的异步编程：Asyncio,创站工坊 滇ICP备2023006006号-44sitemap