如何从已经在循环中运行的“阻塞函数”将协程/任务添加到循环中答案

【问题标题】：How to add a coroutine/task to the loop from a 'blocking function' already running in a loop如何从已经在循环中运行的“阻塞函数”将协程/任务添加到循环中
【发布时间】：2015-10-11 18:35:12
【问题描述】：

希望下面的代码比问题标题更能解释我想做的事情。

import asyncio
import time

loop = asyncio.get_event_loop()

class Foo(object):
    def __init__(self, num):
        self.num = num
    @property
    def number(self):
        # Somehow need to run get_number() in the loop.
        number = self.get_number()
        return number
    @asyncio.coroutine
    def get_number(self):
        yield from loop.run_in_executor(None, time.sleep, self.num)
        return self.num


@asyncio.coroutine
def runner(num):
    print("getting Foo({})".format(num))
    foo = Foo(num)
    yield from asyncio.sleep(1)
    print("accessing number property of Foo({})".format(num))
    number = foo.number
    print("Foo({}) number is {}".format(num, number))


tasks = [
    asyncio.async(runner(3)),
    asyncio.async(runner(1)),
    ]
go = loop.run_until_complete(asyncio.wait(tasks))

我不知道在注释所在的number 函数中要做什么。我尝试了各种各样的事情，但实际上我只是“一直在往墙上扔垃圾，希望有什么能坚持下去”。

这是this question 的后续行动。我想在不执行yield from 的情况下访问该属性，因为我需要从模板（例如mako）访问该属性，并且在任何地方都写有yield from 并不理想（考虑到mako 可能会阻塞，可能甚至不可能）。在一个完美的世界里，我会使用reify decorator 来运行所有这些。

如果我想使用yield from，代码会很简单。

class Foo(object):
    def __init__(self, num):
        self.num = num
    @property
    @asyncio.coroutine
    def number(self):
        yield from loop.run_in_executor(None, time.sleep, self.num)
        return self.num


@asyncio.coroutine
def runner(num):
    print("getting Foo({})".format(num))
    foo = Foo(num)
    yield from asyncio.sleep(1)
    print("accessing number property of Foo({})".format(num))
    number = yield from foo.number
    print("Foo({}) number is {}".format(num, number))

#getting Foo(3)
#getting Foo(1)
#accessing number property of Foo(3)
#accessing number property of Foo(1)
#Foo(1) number is 1
#Foo(3) number is 3

我在该主题上找到了this answer，但我看不出添加完成回调将如何与我的工作流程配合使用。

【问题讨论】：

对不起，你要求的是不可能的事情。没有yield from，就无法从协程中获取值。
我有评论 # Somehow need to run get_number() in the loop. 是我希望创建未来任务并将其放入循环中的地方，从而暂停当前功能 - 我只是不知道该怎么做。例如，将number = self.get_number() 更改为number = loop.create_task(self.get_number())。这可能吗？
@neRok 暂停当前正在运行的函数的唯一方法是使用yield from，这意味着它必须是协程。您可以使用loop.create_task(self.get_number()) 将任务添加到事件循环中，就像您建议的那样，但是在实际调用create_task 的方法通过返回或进行调用将控制权交还给事件循环之前，该任务实际上不会执行使用yield from。将基于 asyncio 的代码集成到同步代码中并不会像您希望的那样工作。
@neRok 有一些方法可以在同步代码和基于asyncio 的代码之间进行某种程度的集成，但与您尝试的方式不同：请参阅stackoverflow.com/q/25299887/2073595 和stackoverflow.com/q/30155138/2073595 .

标签： python python-asyncio

【解决方案1】：

从你的阻塞函数而不是计算值你应该返回asyncio.Future：

return loop.create_task(self.get_number())

当你在你的 async runner 中得到这个时，你可以等待这样的结果：

number = await foo.number

完整的测试用例：

def test_future():
    loop = asyncio.get_event_loop()

    async def target(x: int) -> int:
        loop.run_in_executor(None, time.sleep, 0.1)
        return x + 1

    def intermediate(x: int) -> asyncio.Future:
        return loop.create_task(target(x))

    async def main():
        future = intermediate(5)
        logger.debug('intermediate future = %r', future)
        value = await future
        assert value == 6

    try:
        loop.create_task(main())
        loop.call_later(0.5, loop.stop)
        loop.run_forever()
    finally:
        loop.close()

【讨论】：

【解决方案2】：

你所要求的是不可能的，因为当你在你的主线程中时（你想在没有 yield from 的情况下调用foo.number，你需要明确地将控制权交还给主循环。这正是yield from可以。

否则，您需要在一个单独的线程中运行 调用 foo.number 的函数，该线程将能够阻塞（无从产生）并等待get_number 的结果而不阻塞主循环

【讨论】：