Python线程池 - 创建子任务并等待它们

Question

假设我有一个线程池执行器，最多有10个线程，我向它提交一个任务，这个任务本身会创建另一个任务，然后依次等待它完成，递归地直到达到11个深度。在

Python中的示例代码：

import concurrent.futures

e = concurrent.futures.ThreadPoolExecutor(max_workers=10)

def task(depth):
    print 'started depth %d' % (depth, )
    if depth > 10:
        return depth
    else:
        f = e.submit(task, depth + 1)
        concurrent.futures.wait([f])


f = e.submit(task, 0)
print f.result()

以上代码输出：

^{pr2}$

以及僵局。在

有没有办法在不创建额外的线程和执行器的情况下解决这个问题？在

换句话说，一种让工作线程在等待时处理其他任务的方法？在

Answer 1

不，如果要避免死锁，就不能等待任务中同一个执行器的未来。在

在本例中，您只能返回future，然后递归地处理结果：

import concurrent.futures
import time

e = concurrent.futures.ThreadPoolExecutor(max_workers=10)

def task(depth):
    print 'started depth %d' % (depth, )
    if depth > 10:
        return depth
    else:
        f = e.submit(task, depth + 1)
        return f


f = e.submit(task, 0)
while isinstance(f.result(), concurrent.futures.Future):
    f = f.result()

print f.result()

但是，最好首先避免这种递归执行。在