父进程等待子进程结束

Posted 2021-01-18 tf511

from multiprocessing import  Process
import time

# def task(name):
#     print("%s start" % name)
#     time.sleep(3)
#
#     print("%s stop" % name)
#
# if __name__ == ‘__main__‘:
#     p = Process(target=task,args=("jerry",))
#     p.start()
#     p.join(3)   #父进程必须等到子进程完成后才能继续执行  可设置等待超时时间
#     print("我是主进程!!!")

#——————————————————————————————————————-

def task(i):
    print("%s start" % i)
    # time.sleep(2)
    # print("%s stop" % i)

if __name__ == ‘__main__‘:
    for i in range(1,11):   #开启多个子进程
        p = Process(target=task,args=(i,))
        p.start()
    print("主进程!!!!")

# for i in range(1,11): 等同于下面：
#     p1=Process(target=task,args=(1,))
#     p2=Process(target=task,args=(2,))
#     p3=Process(target=task,args=(3,))
#     p1.start()
#     p2.start()
#     p3.start()


#———————————————————————————————————————

# 我们的代码只负责 通知操作系统创建进程  创建完就继续其他代码
# 但是操作系统什么时候创建完成 什么时候执行我们无法预知无法控制
# def task(i):
#     print("%s start" % i)
#     time.sleep(2)
#     print("%s stop" % i)
#
# if __name__ == ‘__main__‘:
#     start_time = time.time()
#     ps = []
#     for i in range(1,3):
#         p = Process(target=task,args=(i,))
#         p.start()
#         ps.append(p)
#         # 主进程等子进程结束
#     for p in ps:
#         p.join()
#
#     print("主进程!!!!",time.time()-start_time) 

重点： join（）让父进程在原地等待。