理解 asyncio 已经运行永久循环和未决任务

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() 的调用阻塞了；它启动事件循环，并且在您明确停止循环之前不会 return - 因此 run_forever 的 forever 部分。您的程序从未明确停止事件循环，因此您的 asyncio.async(blocking("ls")) 调用永远不会到达。

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

一旦事件循环开始，就将 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：

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

理解 asyncio 已经运行永久循环和未决任务

understanding asyncio already running forever loop and pending tasks

python

python-asyncio

理解 asyncio 已经 运行 永久循环和未决任务

understanding asyncio already running forever loop and pending tasks

python

python-asyncio

理解 asyncio 已经运行永久循环和未决任务