from multiprocessing import Process,Pool
import os,time
print("1")

def Foo(i):
    time.sleep(1)
    print("in process",os.getpid())
    return i+100

def Bar(arg):
    print(">>>>",arg,os.getpid())

if __name__ == "__mian__":
    pool = Pool(processes=3)
    print("主进程:",os.getpid())
    for i in range(10):
        pool.apply_async(func=Foo,args=(i,),callback=Bar)

    print("end")
    pool.close()
    pool.join()