我正在使用这样的 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 这样的顺序产生函数调用。
【问题讨论】：
标签： python multithreading pathos
您需要使用documentation 中描述的锁。
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])
但是，如果您不想并行调用函数，为什么还要使用多处理？
【讨论】：
pathos 作者。有一个很好的中间地带...如果您使用multiprocess 而不是multiprocessing。这是pathos 在幕后使用的库，它提供与multiprocessing 完全相同的接口。因此，如果您使用 pathos 并将其与 multiprocess 中的真正不同接口相结合，它是完全兼容的。