Python并发编程-进程池回调函数

• 回调函数不能传参数
• 回调函数是在主进程中执行的

from multiprocessing import Pool
import  os
def func1(n):
    print('in func1', os.getpid())
    return n*n

def func2(nn):
    print('in func2', os.getpid())
    print(nn)

if __name__ =='__main__':
    print(os.getpid())
    p = Pool(5)
    p.apply_async(func1,args=(10,),callback = func2) #回调函数
    p.close()
    p.join()

>>>
11808
in func1 6352
in func2 11808
100