Skip to content Skip to sidebar Skip to footer

Where To Call Join() When Multiprocessing

When using multiprocessing in Python, I usually see examples where the join() function is called in a separate loop to where each process was actually created. For example, this: p

Solution 1:

join() is blocking operation.

In first example you start 10 processes and then you are waiting for all procces to finish. All processes are running at same time.

In second example you start one process at time and you are waiting for finish before you start another process. There is only one running process at same time

First example:

def wait()
    time.sleep(1)

# You start10 processes
for i inrange(10):
    p = Process(target=wait)
    processes.append(p)
    p.start()

# Onesecond after all processes can be finished you check them alland finish
for p in processes:
    p.join()

Execution time of whole script can be near one second.

Second example:

for i in range(10):
    p = Process(target=wait) # Here you start one process 
    processes.append(p)
    p.start()
    p.join() # Here you will have to wait one second before process finished.

Execution time of whole script can be near 10 seconds!.

Post a Comment for "Where To Call Join() When Multiprocessing"