python – 了解asyncio已经永远运行循环和挂起的任务

我在理解如何将新任务挂起到已经运行的事件循环时遇到了问题.

这段代码：

import asyncio
import logging

@asyncio.coroutine
def blocking(cmd):
    while True:
        logging.info("in blocking coroutine")
        yield from asyncio.sleep(0.01)
        print("ping")

def main():
    logging.info("in main funciton")
    loop = asyncio.get_event_loop()
    logging.info("new loop created")
    logging.info("loop running forever")
    loop.run_forever()
    asyncio.async(blocking("ls"))

logging.basicConfig(level = logging.INFO)
main()

将run_forever()更改为run_until_complete(asyncio.async(blocking(“ls”))工作正常.但我真的很困惑 – 为什么我不能在已经运行的循环上挂起任务？

解决方法

使用asyncio.async将新任务添加到已经运行的循环中是很好的,您只需要确保该函数实际上是从事件循环内的协同程序或回调内部调用的.这里有些例子：

安排阻止在事件循环开始后立即运行：

def main():
    logging.info("in main funciton")
    loop = asyncio.get_event_loop()
    logging.info("new loop created")
    logging.info("loop running forever")
    asyncio.async(blocking("ls"))
    loop.run_forever()

安排阻止事件循环执行的回调：

def start_blocking():
    asyncio.async(blocking("ls"))

def main():
    logging.info("in main funciton")
    loop = asyncio.get_event_loop()
    logging.info("new loop created")
    logging.info("loop running forever")
    loop.call_soon(start_blocking)  # Calls start_blocking once the event loop starts
    loop.run_forever()

（编辑：安卓应用网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!