multiprocessing.Lock 的 concurrent.futures 等价物是什么？

Question

为了保持一致性，我试图移植一些基于multiprocessingto concurrent.futures（使用ProcessPoolExecutor）的旧代码。在我的旧代码中，我使用Lock类将写入同步到标准输出。我似乎无法在concurrent.futures. 有吗？

Answer 1

concurrent.futures 是在 multiprocessing 之上实现的，这就是为什么它本身不提供这样的接口。您可以通过将锁作为作业参数传递给来进行测试。