multiprocessing.Lock 的 concurrent.futures 等价物是什么?
What is the concurrent.futures-equivalent of multiprocessing.Lock?
为了保持一致性,我正在尝试将一些基于 multiprocessing
的旧代码移植到 concurrent.futures
(使用 ProcessPoolExecutor
)。在我的旧代码中,我使用 Lock class 来同步写入标准输出。我似乎无法在 concurrent.futures
中找到类似的 class。有吗?
concurrent.futures 是在 multiprocessing 之上实现的,这就是为什么它本身不提供这样的接口。您可以通过将锁作为作业参数传递给来测试它。
为了保持一致性,我正在尝试将一些基于 multiprocessing
的旧代码移植到 concurrent.futures
(使用 ProcessPoolExecutor
)。在我的旧代码中,我使用 Lock class 来同步写入标准输出。我似乎无法在 concurrent.futures
中找到类似的 class。有吗?
concurrent.futures 是在 multiprocessing 之上实现的,这就是为什么它本身不提供这样的接口。您可以通过将锁作为作业参数传递给来测试它。