python中的进程

Posted 2020-11-02 py01

from multiprocessing import Process,Pool #进程池
import os,time
def run(i):
    time.sleep(1)
    print ("in the process",os.getpid())
    return i+100
def bar(arg):
    print (‘bar is ‘,os.getpid())
if __name__==‘__main__‘:
    p=Pool(5)
    for i in range(10):
        p.apply_async(func=run,args=(i,),callback=bar)#apply是串行执行进程 apply_async是并行执行进程。其中callback是回调方法，调用一个进程结束时执行，用于一些后续工作。如写入数据库日志等。
    p.close()
    p.join()  #必须是先close，然后再join.