代码之家 › 专栏 › 技术社区 › Scott Deerwester

为什么不并发.futures.threadpoolExecutor()。立即提交返回?

python-multithreading concurrency python

Scott Deerwester · 技术社区 · 8 年前

在本代码中:

import concurrent.futures
import time

def pafter(t):
    time.sleep(t)
    print('Hi')

with concurrent.futures.ThreadPoolExecutor(5) as e:
    e.submit(pafter, 2)

print('With returned')

我希望看到:

With returned
Hi

但我明白:

Hi
With returned

为什么不 submit 立即返回?我该如何改变才能做到这一点?

1 回复 | 直到 8 年前

dano 8 年前

使用 with 语句等价于调用 executor.shutdown() , which is documented like this :

shutdown(wait=True)

向执行者发出信号,表示在当前挂起的期货执行完毕时,它应该释放正在使用的任何资源。在关闭后调用executor.submit()和executor.map()将引发RuntimeError。

如果wait为true,则此方法将不会返回,直到所有挂起的期货执行完毕并且与执行者关联的资源被释放为止。 . 如果wait为false,则此方法将立即返回,并且在所有挂起的期货执行完毕后,将释放与执行者关联的资源。不管wait的值是多少,整个python程序都不会退出,直到所有待定的预购完成执行。

如果使用WITH语句,则可以避免显式调用此方法,因为WITH语句将关闭执行器(就像调用executor.shutdown()时wait设置为true一样等待)。

粗体部分解释了你所看到的行为; submit() 呼叫确实立即返回,但 具有 语句将一直阻塞,直到所有提交的工作完成。要更改它,您不需要使用 具有 语句,而不是显式调用 shutdown(wait=False) .

推荐文章

ron burgundy · 获取-释放语义是否跨线程传递?[副本]

1 年前

H3007 · 并发运行python子进程似乎不是并发的

1 年前

The Oddler · TVar会阻止读取直到更改吗?

1 年前

Wang Tuma · 使用信号量的c++并发问题:按顺序打印

2 年前

Ahmed Bilal · Java CopyOnWriteArrayList添加元素(如果不存在)

2 年前

Saurabh Goyal · 为什么Tokio单线程风格不提供任何并发性?

2 年前

KundaliniSin · 异步函数的隐式Promise没有像我预期的那样解析

2 年前

Theodor Zoulias · 列出<T>。AddRange在将ConcurrentDictionary作为参数传递时引发ArgumentException

2 年前

Marcel Batista · 在不同线程中更新密钥时的字典线程安全

2 年前

rico · 当volatile关键字真的是必要的?

2 年前