为何使用concurrent.futures时，executor.map配合futures.as_completed会在任务完成后报错？

嘿，这个问题其实是因为你混淆了executor.map()和futures.as_completed()的设计逻辑，我来给你拆解清楚：

核心问题：executor.map()返回的不是Future对象 #

executor.map()的定位是简化批量任务的提交与结果获取——它会自动帮你提交所有任务，返回的是一个结果迭代器：当你迭代它时，会按输入的顺序依次返回每个任务的执行结果；如果某个任务抛出异常，迭代到对应位置时这个异常就会被抛出。

而futures.as_completed()的作用是接收一堆Future对象，在某个Future完成时（无论成功或失败）立刻返回它，让你可以及时处理结果。但你把executor.map()的返回值传给as_completed()，相当于把“结果迭代器”当成了“Future对象集合”，这完全不符合它的输入要求，自然会触发报错。

两种正确的用法 #

根据你的需求，选下面其中一种写法就可以解决问题：

1. 只使用executor.map()（按输入顺序处理结果）

如果你需要保持任务的输入顺序来获取结果，直接用map()就足够了，不需要搭配as_completed()：

import requests
from concurrent import futures

data = range(10)

def send_request(item):
    resp = requests.get("https://httpbin.org/ip")
    print(f"Request {item} complete.")
    return resp.json()['origin']

executor = futures.ThreadPoolExecutor(max_workers=25)

try:
    # 迭代map的结果，会按data的顺序返回每个任务的结果
    results = executor.map(send_request, data)
    for item, result in zip(data, results):
        print(f"Request {item} returned IP: {result}")
except Exception as e:
    print(f"某个任务出错了: {str(e)}")

2. 使用executor.submit() + futures.as_completed()（完成即处理，不按顺序）

如果想实现“任务完成一个就处理一个”（不关心输入顺序），那就用submit()逐个提交任务，收集所有Future对象后再传给as_completed()：

import requests
from concurrent import futures

data = range(10)

def send_request(item):
    resp = requests.get("https://httpbin.org/ip")
    print(f"Request {item} complete.")
    return item, resp.json()['origin']

executor = futures.ThreadPoolExecutor(max_workers=25)

# 提交所有任务，把Future对象存在列表里
future_tasks = [executor.submit(send_request, item) for item in data]

# 遍历完成的任务，谁先完成谁先处理
for future in futures.as_completed(future_tasks):
    try:
        item, result = future.result()
        print(f"Request {item} returned IP: {result}")
    except Exception as e:
        print(f"任务执行出错: {str(e)}")

总结一下 #

• executor.map()是批量任务的“懒人写法”，帮你封装了提交和按序取结果的逻辑，不需要搭配as_completed。
• as_completed()是用来处理独立提交的Future对象，实现“完成即处理”的需求，这时候要和executor.submit()配合使用。

内容的提问来源于stack exchange，提问作者chhantyal