python async_python async with和async for的使用
网上async with和async for的中文资料比较少,我把PEP 492中的官方陈述翻译一下。
异步上下文管理器”async with”
异步上下文管理器指的是在enter和exit方法处能够暂停执行的上下文管理器。
为了实现这样的功能,需要加入两个新的方法:__aenter__ 和__aexit__。这两个方法都要返回一个 awaitable类型的值。
异步上下文管理器的一种使用方法是:
class AsyncContextManager:
async def __aenter__(self):
await log('entering context')
async def __aexit__(self, exc_type, exc, tb):
await log('exiting context')
新语法
异步上下文管理器使用一种新的语法:
async with EXPR as VAR:
BLOCK
这段代码在语义上等同于:
mgr = (EXPR)
aexit = type(mgr).__aexit__
aenter = type(mgr).__aenter__(mgr)
exc = True
VAR = await aenter
try:
BLOCK
except:
if not await aexit(mgr, *sys.exc_info()):
raise
else:
await aexit(mgr, None, None, None)
和常规的with表达式一样,可以在一个async with表达式中指定多个上下文管理器。
如果向async with表达式传入的上下文管理器中没有__aenter__ 和__aexit__方法,这将引起一个错误 。如果在async def函数外面使用async with,将引起一个SyntaxError(语法错误)。
例子
使用async with能够很容易地实现一个数据库事务管理器。
async def commit(session, data):
...
async with session.transaction():
...
await session.update(data)
...
需要使用锁的代码也很简单:
async with lock:
...
而不是:
with (yield from lock):
...
异步迭代器 “async for”
一个异步可迭代对象(asynchronous iterable)能够在迭代过程中调用异步代码,而异步迭代器就是能够在next方法中调用异步代码。为了支持异步迭代:
1、一个对象必须实现__aiter__方法,该方法返回一个异步迭代器(asynchronous iterator)对象。
2、一个异步迭代器对象必须实现__anext__方法,该方法返回一个awaitable类型的值。
3、为了停止迭代,__anext__必须抛出一个StopAsyncIteration异常。
异步迭代的一个例子如下:
class AsyncIterable:
def __aiter__(self):
return self
async def __anext__(self):
data = await self.fetch_data()
if data:
return data
else:
raise StopAsyncIteration
async def fetch_data(self):
...
新语法
通过异步迭代器实现的一个新的迭代语法如下:
async for TARGET in ITER:
BLOCK
else:
BLOCK2
这在语义上等同于:
iter = (ITER)
iter = type(iter).__aiter__(iter)
running = True
while running:
try:
TARGET = await type(iter).__anext__(iter)
except StopAsyncIteration:
running = False
else:
BLOCK
else:
BLOCK2
把一个没有__aiter__方法的迭代对象传递给 async for将引起TypeError。如果在async def函数外面使用async with,将引起一个SyntaxError(语法错误)。
和常规的for表达式一样, async for也有一个可选的else 分句。.
例子1
使用异步迭代器能够在迭代过程中异步地缓存数据:
async for data in cursor:
...
这里的cursor是一个异步迭代器,能够从一个数据库中每经过N次迭代预取N行数据。
下面的语法展示了这种新的异步迭代协议的用法:
class Cursor:
def __init__(self):
self.buffer = collections.deque()
async def _prefetch(self):
...
def __aiter__(self):
return self
async def __anext__(self):
if not self.buffer:
self.buffer = await self._prefetch()
if not self.buffer:
raise StopAsyncIteration
return self.buffer.popleft()
接下来这个Cursor 类可以这样使用:
async for row in Cursor():
print(row)
which would be equivalent to the following code:
i = Cursor().__aiter__()
while True:
try:
row = await i.__anext__()
except StopAsyncIteration:
break
else:
print(row)
例子2
下面的代码可以将常规的迭代对象变成异步迭代对象。尽管这不是一个非常有用的东西,但这段代码说明了常规迭代器和异步迭代器之间的关系。
class AsyncIteratorWrapper:
def __init__(self, obj):
self._it = iter(obj)
def __aiter__(self):
return self
async def __anext__(self):
try:
value = next(self._it)
except StopIteration:
raise StopAsyncIteration
return value
async for letter in AsyncIteratorWrapper("abc"):
print(letter)
为什么要抛出StopAsyncIteration?
协程(Coroutines)内部仍然是基于生成器的。因此在PEP 479之前,下面两种写法没有本质的区别:
def g1():
yield from fut
return 'spam'
和
def g2():
yield from fut
raise StopIteration('spam')
自从 PEP 479 得到接受并成为协程 的默认实现,下面这个例子将StopIteration包装成一个RuntimeError。
async def a1():
await fut
raise StopIteration('spam')
告知外围代码迭代已经结束的唯一方法就是抛出StopIteration。因此加入了一个新的异常类StopAsyncIteration。
由PEP 479的规定 , 所有协程中抛出的StopIteration异常都被包装在RuntimeError中。
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持我们。
本文标题: python async with和async for的使用
本文地址: http://www.cppcns.com/jiaoben/python/262859.html
python async_python async with和async for的使用相关推荐
- Python 3.5将支持Async/Await异步编程
根据Python增强提案(PEP) 第0492号, Python 3.5将通过async和await语法增加对协程的支持.该提案目的是使协程成为Python语言的原生特性,并"建立一种普遍. ...
- async function_掌握 Async/Await
摘要: 还不用Async/Await就OUT了.. 原文:掌握 Async/Await 作者:Jartto Fundebug经授权转载,版权归原作者所有. 前端工程师肯定都经历过 JS 回调链狱的痛苦 ...
- ajax on ture,细数Ajax请求中的async:false和async:true的差异
实例如下: function test(){ var temp="00"; $.ajax({ async: false, type : "GET", url : ...
- python3.5怎么使用-如何在Python 3.5中使用async/await?
运行协同程序需要事件循环.使用 asyncio() library创建一个: import asyncio loop = asyncio.get_event_loop() loop.run_until ...
- python中await async_[转载]python中的await和async
原文https://blog.csdn.net/Likianta/article/details/90123678 from time import sleep, time def demo1(): ...
- @async注解_Spring @Async 使用
开启异步支持 @Configuration@EnableAsyncpublic class SpringAsyncConfig { ... } 默认情况下,@EnableAsync检测Spring的@ ...
- 使用ajax async,Ajax请求async有哪些方式?应该如何使用
这次给大家带来Ajax请求async有哪些方式?应该如何使用,Ajax请求async的注意事项有哪些,下面就是实战案例,一起来看一下. test.html代码: asy.js代码:function t ...
- async 函数 ajax,Async 函数的使用及简单实现
解决回调地狱的异步操作,Async 函数是终极办法,但了解生成器和 Promise 有助于理解 Async 函数原理.由于内容较多,分三部分进行,这是第三部分,介绍 Async 函数相关.第一部分介绍 ...
- Python 异步 IO 、协程、asyncio、async/await、aiohttp
From :廖雪峰 异步IO :https://www.liaoxuefeng.com/wiki/1016959663602400/1017959540289152 Python Async/Awai ...
最新文章
- 干货!如何设计实现一个通用的分布式事务框架?
- day03: oracle的sql增 、删、改,事务处理
- WinCE文件目录定制
- 魔众商城系统源码 v4.0.0 beta
- blendshape变形器详细解释
- 英语诗歌选读 | 期末总结
- xxx(telnet, netstat): command not found
- ESP8266AT固件获取时间和连接心知天气
- 2.28 内置对象 (查阅MDN)
- 静态路由、策略路由与NQA联动
- unity3d中ScriptingBackend选择mono和il2cpp的区别
- 离散数学第二章 谓词逻辑
- 关于matlab licence许可到期问题
- 【每天一个java设计模式(十七)】 - 状态模式
- 网页制作APP和APP定制开发有哪些区别
- 算法(1)—— 冒泡排序
- 地震中,那些正在传递的“正能量”
- Linux内核源代码目录树结构
- QQ删除好友后,对方还能否在好友列表看到本人?
- redis用于php购物,PHP+redis实现的购物车单例类示例
热门文章
- java 的分类_java的基本类型(转)
- centos7创建asm磁盘_Oracle ASM 磁盘组基础知识整理(收藏版)
- 微型计算机可以处理的二进制数据长度,可以处理二进制数据长度的是
- Android服务器django,Android发送发送请求到django服务器csrf失败
- java 删除压缩zip文件_从ZIP存档中删除文件,而无需在Java或Python中解压缩 - java...
- Number With The Given Amount Of Divisors(反素数)
- 容器大小_C++ 顺序容器基础知识总结
- linux重装出现cannot load file 5555h,重装win7系统开机提示cannot load file code:5555h怎么办...
- 计算机组成原理--主存储器
- 如何解决Qt程序在其他电脑上无法运行的问题(Qt程序打包发布)