蟒蛇期货和元组拆包

Question

什么是实现类似元组解包与期货类似的方式/习惯用法？

我有一个像

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电话？即。我想，以避免必须写为：

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。

Answer 1

快速浏览一下：

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的回答表明，链接期货是不平凡：

How to chain futures in a non-blocking manner? That is, how to use one future as an input in another future without blocking?