for future in concurrent.futures.as_completed(results):用法
时间: 2024-02-04 17:03:09 浏览: 169
在 Python 的 `concurrent.futures` 模块中,`as_completed` 方法是一个生成器函数,它用于获取一组任务的执行结果。它接受一个参数,即一个 `Future` 对象的迭代器(通常是一个列表),并返回一个迭代器,该迭代器按照任务完成的顺序返回每个任务的执行结果。
具体来说,`as_completed` 方法会在每个任务完成时返回一个 `Future` 对象,我们可以通过 `Future.result()` 方法获取任务的实际执行结果。在使用 `as_completed` 方法时,通常使用 `for` 循环遍历每个任务的执行结果,如下所示:
```python
import concurrent.futures
# 定义一个任务函数
def task(num):
return num ** 2
# 创建一个线程池
with concurrent.futures.ThreadPoolExecutor(max_workers=3) as executor:
# 向线程池提交任务
results = [executor.submit(task, i) for i in range(10)]
# 获取任务的执行结果
for future in concurrent.futures.as_completed(results):
print(future.result())
```
在上述示例中,我们使用 `as_completed` 方法获取每个任务的执行结果,并在循环中使用 `future.result()` 方法获取每个任务的实际执行结果。由于 `as_completed` 方法按照任务完成的顺序返回每个任务的执行结果,因此输出的结果也是按照任务完成的顺序输出的。
阅读全文