如何确保在 Python 中始终使用多个线程连续进行两个函数调用

Question

我像这样使用Pathos：

from pathos.multiprocessing import ProcessingPool as Pool
def foo(bar):
   fn1(bar)
   fn2(bar)
Pool().map(foo, data)

我希望fn1和fn2作为一个原子操作执行，这样没有线程可以像fn1, fn1, fn2, fn2这样的序列产生函数调用。

Answer 1

您需要使用文档中描述的锁。

def foo(lock, bar):
    lock.acquire()
    try:
       fn1(bar)
       fn2(bar)
    finally:
        lock.release()
if __name__ == '__main__':
    lock = Lock()
    Pool().map(foo, [(l, d) for d in data])

但是，如果您不想并行调用函数，为什么要使用多处理？