python - 如何从已经在循环中运行的 'blocking function' 添加协程/任务到循环

Question

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

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关于这个主题，但我看不出添加完成的回调如何与我的工作流程一起工作。

Answer 1

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

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