python 线程池as_completed

`concurrent.futures.as_completed()`是一个非常有用的函数，它可以迭代返回已完成的`Future`对象。在使用线程池执行一批任务时，可以使用`as_completed()`来获取已完成的任务的结果。

下面是一个示例：

import concurrent.futures

# 定义一个任务函数
def task(name):
    print(f"Task {name} starting")
    # 执行具体任务的代码
    print(f"Task {name} done")
    return f"Task {name} result"

# 创建线程池
with concurrent.futures.ThreadPoolExecutor() as executor:
    # 提交任务到线程池
    futures = [executor.submit(task, i) for i in range(5)]

    # 获取已完成任务的结果
    for future in concurrent.futures.as_completed(futures):
        result = future.result()
        print(result)

在上面的示例中，我们首先定义了一个任务函数`task`，然后使用`ThreadPoolExecutor`创建了一个线程池，并使用`submit`方法提交了5个任务到线程池中。返回的`futures`是一个包含所有任务的`Future`对象列表。

接下来，在使用`as_completed()`函数时，它会返回一个迭代器，可以逐个获取已完成的任务。我们使用`future.result()`方法获取任务的结果，并打印出来。

需要注意的是，`as_completed()`函数返回的是一个迭代器，它会按照任务完成的顺序返回结果。如果一个任务比其他任务耗时更长，那么在迭代结果时，可能会先返回其他任务的结果。因此，你可以根据实际需求来处理返回的结果。