Python 生成器和减少

Question

我正在使用@gen.coroutine 装饰器为 GET 请求提供异步协程的 Python3 tornado Web 服务器。我想使用库中的这个函数：

@gen.coroutine
def foo(x):
    yield do_something(x)

这很简单：

@gen.coroutine
def get(self):
    x = self.some_parameter
    yield response(foo(x))

现在假设有多个相同类型的函数foo1、foo2等。我想做...foo3(foo2(foo1(x).result()).result())... 和yield 之类的事情，而不仅仅是get 方法中的response(foo(x))。

我认为使用reduce 和result 方法会很容易。但是，由于tornado 的工作方式，我无法强制foos 使用result 方法返回某些内容。这意味着yield reduce(...) 给出错误：“DummyFuture 不支持结果阻塞”。从 SO 和其他地方的其他答案中，我知道我将不得不使用 IOLoop 或其他我不太了解的东西，并且...

...我的问题是，我如何避免从 get 方法评估 all foos 和 yield 未评估的块？

编辑：这不是this question 的重复，因为我想：1. 嵌套很多函数，2. 尝试 not 立即评估。

Answer 1

在 Tornado 中，您必须在协程中 yield 一个 Future 才能获得结果。评论Tornado's coroutine guide。

你可以写一个协程的reducer。它运行每个协程以获取 Future，使用 Future 调用 yield 以获取结果，然后在该结果上运行下一个协程：

from tornado.ioloop import IOLoop
from tornado import gen


@gen.coroutine
def f(x):
    # Just to prove we're really a coroutine.
    yield gen.sleep(1)
    return x * 2


@gen.coroutine
def g(x):
    return x + 1


@gen.coroutine
def h():
    return 10


@gen.coroutine
def coreduce(*funcs):
    # Start by calling last function in list.
    result = yield funcs[-1]()

    # Call remaining functions.
    for func in reversed(funcs[:-1]):
        result = yield func(result)

    return result


# Wrap in lambda to satisfy your requirement, to 
# NOT evaluate immediately.
latent_result = lambda: coreduce(f, g, h)
final_result = IOLoop.current().run_sync(latent_result)
print(final_result)