使用asyncio时,为了保持低延迟,协同路由不应该在两次之间花费很长时间。你知道吗
为了确保这一点,记录长时间运行可能是有用的。你知道吗
一个可运行的例子演示了我的意思:
#!/usr/bin/env python3
import time
from time import monotonic_ns
import asyncio
from pyaux.runlib import init_logging
init_logging(level=1)
state = {}
class LoggyLoopMixin:
_warn_run_once_time = 0.2
def _run_once(self):
start_time = monotonic_ns()
result = super()._run_once()
end_time = monotonic_ns()
self._check_run_once_time_diff(start_time=start_time, end_time=end_time)
def _check_run_once_time_diff(self, start_time, end_time):
time_diff = (end_time - start_time) / 1e9
if time_diff > self._warn_run_once_time:
self._handle_run_once_time_diff(time_diff=time_diff)
def _handle_run_once_time_diff(self, time_diff, **kwargs):
print("WARNING: large run_once time difference: %.3fs" % (time_diff,))
def mixin_asyncio_loop(mixin_cls):
superclass = asyncio.get_event_loop_policy().__class__
# assuming that `superclass._loop_factory` is a class.
# pylint: disable=protected-access
class MixinnedEventLoop(mixin_cls, superclass._loop_factory):
""" ... """
class MixinnedEventLoopPolicy(superclass):
_loop_factory = MixinnedEventLoop
elp = MixinnedEventLoopPolicy()
asyncio.set_event_loop_policy(elp)
return elp
mixin_asyncio_loop(LoggyLoopMixin)
async def heartbeat(sleep_time=0.1, warn_time=0.2):
"""
An on-top-of-the-loop implementation, which is even worse.
See: https://github.com/pebble/event-loop-lag
"""
prev = monotonic_ns()
warn_time_ns = int(warn_time * 1e9)
while True:
now = monotonic_ns()
if now - prev > warn_time_ns:
print("Hearbeat missed (%.3fs from last)" % ((now - prev) / 1e9,))
else:
print("Heartbeat time: %d" % (now - prev,))
prev = monotonic_ns()
await asyncio.sleep(sleep_time)
async def amain():
# asyncio.ensure_future(heartbeat())
sleep_time = 0.01
while sleep_time < 3.5:
print("Busy for %.3fs" % (sleep_time,))
# await asyncio.sleep(sleep_time)
time.sleep(sleep_time)
await asyncio.sleep(0.001) # yield at all
sleep_time *= 1.5
def main():
loop = asyncio.get_event_loop()
loop.run_until_complete(amain())
if __name__ == '__main__':
main()
但是,我希望已经有了它的实现,感觉好像我以前见过这个特性,但是找不到它。你知道吗
而且,as it has been noted elsewhere,不鼓励对asyncio进行子类化。你知道吗
是否有此功能的现有实现?你知道吗
是的,它是事件循环的debug mode。你知道吗
按以下方式更改代码以查看结果:
您将看到如下内容:
相关问题 更多 >
编程相关推荐