파이썬 future와 tuple unpacking

Question

future를 가지고 튜플을 언 패킹하는 것과 같은 것을 달성하기위한 elagant/idiomatic 한 방법은 무엇입니까?

나는

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

과 같은 코드를하고 난 미래를 사용하도록 변환하고 싶습니다. 이상적으로 그의 첫 번째 줄은 생각

TypeError: 'Future' object is not iterable 

가 발생합니다

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

같은 것을 쓰고 싶습니다. 을 3 번 추가하지 않고도 a,b,c을 얻으려면 어떻게해야합니까? 즉. 나는이로 작성하는 것을 피하기 위해 싶습니다 예를 들어 당신이 경우 첫 번째 :

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?