python future 和元组解包

实现像使用 future 进行元组解包这样的事情的优雅/惯用的方法是什么？

我有这样的代码

a, b, c = f(x)
y = g(a, b)
z = h(y, c)

我想将其转换为使用期货。 理想情况下我想写一些类似的东西

a, b, c = ex.submit(f, x)
y = ex.submit(g, a, b)
z = ex.submit(h, y, c)

第一行抛出

TypeError: 'Future' object is not iterable

尽管。 我怎样才能得到a,b,c无需额外制作3个ex.submit打电话？ IE。我想避免将其写为：

import operator as op
fut = ex.submit(f, x)
a = client.submit(op.getitem, fut, 0)
b = client.submit(op.getitem, fut, i)
c = client.submit(op.getitem, fut, 2)
y = ex.submit(g, a, b)
z = ex.submit(h, y, c)

我想一个潜在的解决方案是写一个unpack函数如下所示，

import operator as op
def unpack(fut, n):
    return [client.submit(op.getitem, fut, i) for i in range(n)]

a, b, c = unpack(ex.submit(f, x), 3)
y = ex.submit(g, a, b)
z = ex.submit(h, y, c)

有效：例如，如果您首先定义：

def f(x):
    return range(x, x+3)
x = 5
g = op.add
h = op.mul

然后你得到

z.result() #===> 77

我想这样的东西可能已经存在了。

以上仅适用于dask.distributed.Future。它不适用于普通concurrent.futures.Future.

快速浏览一下：

https://docs.python.org/3/library/concurrent.futures.html#concurrent.futures.Future https://docs.python.org/3/library/concurrent.futures.html#concurrent.futures.Future

建议你必须做类似的事情

afuture = ex.submit(f, x)
a,b,c = afuture.result()
...

submit返回一个Future对象，而不是运行的结果f(x).

这个 SO 答案表明链接期货并不是微不足道的：

如何以非阻塞的方式上链期货？即如何在不阻塞的情况下将一个 future 作为另一个 future 的输入？ https://stackoverflow.com/questions/45922846/how-to-chain-futures-in-a-non-blocking-manner-that-is-how-to-use-one-future-as