Python异步调用单独的函数

Question

我有以下4个函数，其中3个调用外部api来获取随机数据：

def get_external_data(zip_code, info_code):
    data_url = MY_ENDPOINT_1.format(zip_code)
    data_response = requests.request(
        'GET',
        url=data_url,
        headers={
            'content-Type': 'application/json',
            'info-code': info_code
        }
    )
    return data_response

def get_info(info_code):
    info_url = INFO_URL.format(info_code)
    info_response = requests.request(
        'GET',
        url=info_url,
        headers={
            'content-Type': 'application/json',
            'info-code': info_code
        }
    )
    return info_response

def get_zip(zip_code):
    zip_url = zip_URL.format(zip_code)
    zip_response = requests.request(
        'GET',
        url=zip_url,
        headers={
            'content-Type': 'application/json',
            'zip-code': zip_code
        }
    )
    return zip_response

def get_all_data(info_cd, zip_code):
    data_response = get_external_data(zip_code, info_cd)
    info_response = get_info(info_cd)
    zip_response = get_zip(zip_code)
    return data_response, info_response, zip_response

我正在尝试通过concurrent.futures函数中的get_all_data()调用3个数据函数来实现3个异步调用。从文档中我了解到，我们可以使用输入列表来串扰一个函数，如下所示：

resp_list = list()
# Asynchronous
with ThreadPoolExecutor(max_workers=3) as executor:
    thread_responses = executor.map(self.get_info, info_list)
    for x in thread_responses:
        resp_list.append(x)

但是在这种特殊情况下，如何用3个不同的功能，不同的输入实现3个线程？

Answer 1

您可以使用executor.submit在自己的线程中进行每个调用，如下所示：

with ThreadPoolExecutor(max_workers=3) as executor:
    data_future = executor.submit(get_external_data, zip_code, info_cd)
    info_future = executor.submit(get_info, info_cd)
    zip_future = executor.submit(get_zip, zip_code)
    # and then collect results
    results = [
        f.result()
        for f in (data_future, info_future, zip_future)
    ]

请参阅相关文档：https://docs.python.org/3/library/concurrent.futures.html#concurrent.futures.Executor.submit