带有上下文管理器的 ThreadPoolExecutor

Question

我不明白为什么这段代码的行为方式不同。在第一种情况下，代码将打印“elo”，19 秒后我们将看到“3”。

在其他情况下，我们将首先等待 19 秒，然后我们将看到“elo”。

你能解释一下吗？

from concurrent.futures import ThreadPoolExecutor

def wait_on_future():
    f = 3
    import time
    time.sleep(19)
    print(f)

executor = ThreadPoolExecutor(max_workers=2)
executor.submit(wait_on_future)
print("elo")

对

from concurrent.futures import ThreadPoolExecutor

def wait_on_future():
    f = 3
    import time
    time.sleep(19)
    print(f)

with ThreadPoolExecutor(max_workers=2) as executor:      
    executor.submit(wait_on_future)
print("elo")

Answer 1

您的第一个程序没有明确关闭池。您使用executor.submit() 提交您的任务，这是一个非阻塞调用。您的主程序立即处理打印语句并挂在那里，直到所有线程在 19 秒后完成。

您的第二个程序使用 with 语句，在这种情况下它是阻塞的。 with ThreadPoolExecutor() 有一个隐含的shutdown(wait=True)，它会阻塞在那里，直到所有线程都完成处理。见https://docs.python.org/3/library/concurrent.futures.html

这使您的程序 1 在功能上与您的程序 2 相同：

executor = ThreadPoolExecutor(max_workers=2)
executor.submit(wait_on_future)
executor.shutdown(wait=True)
print("elo")

希望这会有所帮助。