了解asyncio已经在运行forever循环和挂起的任务

Question

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

此代码：

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"))效果很好。但是我真的很困惑-为什么我不能把一个任务挂在已经运行的循环上？在

Answer 1

问题是对loop.run_forever()的调用会阻塞；它启动事件循环，并且在您显式停止循环之前不会返回-因此run_forever的forever部分。您的程序从不显式停止事件循环，因此您的asyncio.async(blocking("ls"))调用永远不会到达。在

使用asyncio.async将新任务添加到已在运行的循环中是可以的，您只需确保该函数实际上是从事件循环中的协同例程或回调中调用的。以下是一些示例：

安排blocking在事件循环启动后立即运行：

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()

从事件循环执行的回调中调度blocking：

^{pr2}$