了解异步已在运行的永久循环和挂起任务 [英] understanding asyncio already running forever loop and pending tasks

问题描述

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

此代码：

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"))可以正常工作。但我真的很困惑-为什么我不能在已经运行的循环上挂起任务？

推荐答案

问题是对loop.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：

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

这篇关于了解异步已在运行的永久循环和挂起任务的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！