python--進程鎖、進程池

進程鎖：

from multiprocessing import Process, Lock

def f(l, i):
    l.acquire()

    print('hello world', i)

    l.release()

if __name__ == '__main__':
    lock = Lock()

    for num in range(10):
        Process(target=f, args=(lock, num)).start()

 

進程池：

from multiprocessing import Process, Pool
import time

def Foo(i):
    time.sleep(2)
    return  i+100

def Bar(arg):
    print('----->exec done:',arg)

pool = Pool(5)  #允許進程池里同時放入5個進程

for i in range(10):
    pool.apply_async(func=Foo,args=(i,),callback=Bar)  #並行執行，callback回調執行者為父進程
    #pool.apply(func=Foo, args=(i,))  #串行執行

print('end')
pool.close()
pool.join()  #進程池中進程執行完畢后再關閉，如果注釋，那么程序直接關閉。