Python concurrent.futures:线程不会启动

Question

我制作了一个程序，使用concurrent.futures启动4个线程，并将请求发送到列表中的每个网站。

问题:它只是没有开始

import requests
import threading
import concurrent.futures

list=['amazon.com', 'google.com', 'youtube.com', 'microsoft.com']

def start(url):
    requests.get('https://'+url)
    print(line+' finished')

with concurrent.futures.ThreadPoolExecutor(max_workers=4) as executor:
    for url in list:
        executor.submit(start, url)

另一方面，这是可行的：

import concurrent.futures

def start():
    print('lol')

with concurrent.futures.ThreadPoolExecutor(max_workers=4) as executor:
    for i in range(10):
        executor.submit(start)

Answer 1

您刚刚安排了任务，但不等待结果，代码中有一个错误(使用未定义的变量)，但是错误消息被上下文管理器“吞没”了。

executor.submit方法返回一个未来对象，在该对象中，可以通过调用结果方法获得返回值：

import requests
import threading
import concurrent.futures

URLS = ['amazon.com', 'google.com', 'youtube.com', 'microsoft.com']


def start(url):
    requests.get('https://' + url)
    print(f'{url}: finished')


def main():
    futures = []

    with concurrent.futures.ThreadPoolExecutor(max_workers=4) as executor:
        for url in URLS:
            futures.append(executor.submit(start, url))

        for future in futures:
            future.result()


if __name__ == "__main__":
    main()