蟒蛇期货和元组拆包
什么是实现类似元组解包与期货类似的方式/习惯用法?蟒蛇期货和元组拆包
我有一个像
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
。
快速浏览一下:
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的回答表明,链接期货是不平凡:
'未来。result()'调用将阻止对'f'的调用,这违背了使用期货的目的。 –
@DanielMahler,你能给我们举一个没有拆箱的链接的例子吗?听起来你已经用“期货”做了一些基本的东西。启发我们。这3个额外的电话是什么? – hpaulj
“抛出一个错误。”什么错误? –
@JohnZwinck'TypeError:'Future'object is not iterable' –
'operator.itemgetter'可以获取多个项目。但看看它的代码;这是一个迭代的类。 – hpaulj