在python中编写未来(asyncio)

我试图在Python中实现一个简单的actor系统,以开发关于并发编程的一些见解。

我主要关注的是在python中编写期货的一般任务,使用 asyncio 模块。

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

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() 最后。或者我想的都不对。