python - 如何确保 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])

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