Wie kann ich sicherstellen, dass zwei Funktionsaufrufe immer hintereinander mit mehreren Threads in Python gemacht werden?

Question

Ich bin mit Pathos wie folgt aus:

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

Pool().map(foo, data) 

Ich möchte fn1 und fn2 als eine atomare Operation ausgeführt werden, so dass keine Threads Funktionsaufrufe in einer Sequenz wie fn1, fn1, fn2, fn2 produzieren kann.

Answer 1

Sie müssen ein Schloss verwenden, wie es in der documentation beschrieben ist.

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]) 

Aber warum verwenden Sie Multiprocessing, wenn Sie Ihre Funktion nicht parallel aufrufen möchten?