关于内置函数的Python协程
作者:互联网
我目前正在使用python 3.4,@ coroutine decorator和yield关键字(在龙卷风中)用于异步目的.
我写了一个带有很多对象instros的ORM,它调用了一个“慢”数据库并覆盖内置函数,如__init__或__contains__.
我的问题是:
例如,当我的异步代码在对象的__contains__定义中时,当我在龙卷风控制器中使用“in”运算符时,如何隐式/透明地调用它?
隐含,因为我不希望控制器端开发人员在调用内置函数时更改其代码.
解决方法:
如果我理解这个问题,那么答案就是你做不到;没有办法将魔术方法编写为显式协程,并且在Python隐式调用时使其行为正常.这是well-known limitation的显式协同程序.
所以,如果你有这个:
class SomeObj:
@coroutine
def __contains__(self, obj):
exists = yield self.somemethod(obj)
return exists
这不会做你想做的事:
o = SomeObj()
'x' in o # This won't work right
Python不希望__contains__成为一个协同程序,并且如果它不会正常运行 – 该语言的核心对龙卷风,asyncio或用于实现这些协同程序的任何其他框架都不了解,并赢得了’与他们妥善整合.这同样适用于其他隐式调用的魔术方法,如__init __,__ getattr__等.
如果需要挂起,则必须使用yield或yield显式调用方法(取决于框架).通常,这意味着使用函数(或者可能是@classmethod)来实例化SomeObj,然后让该函数调用一个执行慢速异步调用的方法,而不是在__init__中完成所有操作:
@coroutine
def create_someobj():
s = SomeObj()
yield s.slow_init()
return s
只是调用一个普通的协程方法,称为包含而不是依赖于in关键字.不理想,但这就是我们生活的世界.
也就是说,正在努力改善这一点; PEP 492,除了为协同程序引入新语法之外,还添加了对异步for循环和上下文管理器的支持(使用专门设计为异步的新魔术方法).所以从Python 3.5开始,你可以这样:
async def some_func(): # async is used instead of a coroutine decorator
# Assume SomeObj implements __anext__, __aiter__, __aenter__, and __aexit__
s = SomeObj()
async for item in s: # You can suspend while iterating over s using __anext__
print(item)
async with SomeObj() as s: # You can suspend on enter and exit of this context manager using __aenter__ and __aexit__
await s.some_method() # await is used instead of yield from
标签:python,coroutine,tornado,built-in,python-asyncio 来源: https://codeday.me/bug/20190612/1222601.html