用 Python 编写期货（asyncio）

Question

我正在尝试在 Python 中实现一个简单的演员系统，以深入了解并发编程。

我主要关心的是使用 asyncio 模块在 Python 中编写期货的通用任务。

假设我有一个在单独的线程上运行的事件循环。

import asyncio

from threading import Thread

loop = asyncio.new_event_loop()


def run_event_loop(loop):
    asyncio.set_event_loop(loop)
    loop.run_forever()


t = Thread(target=run_event_loop, args=(loop,))
t.start()

为了避免同步通信，我需要能够以某种方式编写Futures。举个简单的例子，假设我想合并两个 async 协程的结果。

我的第一次（显然是错误的）尝试：

async def f(x):
    fut = asyncio.run_coroutine_threadsafe(g(x / 2), loop)
    return fut

async def g(x):
    return x * 2

f(x) = x / 2

g(x) = x * 2

f(g(x)) = x

我无法得出一个干净的解决方案来处理以下一般问题：

x = 10

future = asyncio.run_coroutine_threadsafe(f(x), loop)

print(future)                    # <Future at 0x106f797f0 state=pending>

print(future.result())           # <Future at 0x10677c780 state=finished returned float>

print(future.result().result())  # 10.0

理想情况下，我应该结合期货并在最后执行一个future.result()。或者，也许我对这一切的思考都错了。

Answer 1

这里的根本问题是：

fut = asyncio.run_coroutine_threadsafe(g(x / 2), loop)

您在 async 函数中，并试图在同一线程的同一事件循环中运行另一个异步函数。你不需要run_coroutine_threadsafe。就await吧。

如果您仍然拨打run_coroutine_threadsafe 会发生什么？然后你得到的是concurrent.futures.Future。正如asyncio 文档顶部所解释的，这与asnycio.Future 不同——后者旨在模仿一个并发的未来，但在幕后它是另一回事。您可以组合两个 asyncio 未来（来自同一个事件循环），您可以组合两个并发未来，但不能用异步未来组合一个并发未来。

您可以将并发未来包装在异步未来中（直接使用wrap_future，或者更常见的是间接通过run_in_executor）。但是你最终会得到一个并发未来持有一个异步未来包装一个并发未来，它仍然无法组合。