1.导入进程包
import multiprocessing
multiprocessing 是一个支持使用与 threading 模块类似的 API 来产生进程的包。 multiprocessing 包同时提供了本地和远程并发操作,通过使用子进程而非线程有效地绕过了 全局解释器锁。 因此,multiprocessing 模块允许程序员充分利用给定机器上的多个处理器。 它在 Unix 和 Windows 上均可运行。
2.创建进程
Process([group [, target [, name [, args [, kwargs]]]]])
group参数未使用,值始终为None
target表示调用对象,即子进程要执行的任务
args表示调用对象的位置参数元组,args=(1,2,'hello',)
使用multiprocessing.Process创建进程,target表示要执行的函数,可以使用args传入元组必须要用逗号如
args=('张三',)或者用kwarges传入字典需要使用关键字的方式来指定参数,如kwargs={'name':'zhangsan','age':18}
#创建进程 sub_process = multiprocessing.Process(target=task)
3.启动进程
#启动进程 sub_process.start()
常用方法
start()启动子进程实例
join()等待子进程执行结束
terminate()不管任务是否完成 立即终止
4.最终实现
import multiprocessing import time def dance(): for i in range(5): print("dance...") time.sleep(1) def sing(): for i in range(5): print("sing...") time.sleep(1) # 判断是否是直接执行的模块, 程序入口模块 # 标准python写法,直接执行的模块,需要加上判断是否是主模块的代码 if __name__ == '__main__': #创建 dance_process = multiprocessing.Process(target=dance) sing_process = multiprocessing.Process(target=sing) #启动 dance_process.start() sing_process.start()
输出结果:
dance... sing... dance... sing... dance... sing... dance... sing... dance... sing...