python - 在范围内调用asyncio Future

我正在尝试使asyncIO Futures不断发展。由于某种原因，我无法在任何其他范围内获得价值更新。

例如：

import concurrent.futures
import time
import asyncio
import random

def get_progress(futures):
    return sum([f.done() for f in futures])

def long_task(t):
    time.sleep(1.5)
    return t

loop = asyncio.get_event_loop()
executor = concurrent.futures.ProcessPoolExecutor(max_workers=4)
inputs = ['a', 'b', 'c', 'd', 'e', 'f', 'g']
futures_ = [loop.run_in_executor(executor, long_task, i) for i in inputs]

for i in range(5):
    time.sleep(1)
    print(get_progress(futures_))

仅打印0。但是，如果我在终端中运行此程序并调用get_progress(futures_)它，则会按预期打印7。

我在这里想念什么吗？

查看更多