导入
import multiprocessing
multiprocessing对象
创建进程对象(p)
直接创建
【资料图】
p = multiprocessing.Process(target,args,kwargs)
target:传入线程函数
args:传递函数参数(没有可忽略,传递加括号,结束加逗号)如args=(1,)
kwargs:指定函数传参(字典)
以类创建(继承)
例如:
class Task(multiprocessing.Process):
def run(self):
需要运行的代码
(在类中定义的其他函数要在run(名字不能改)函数里才能运行,启动同下)
线程对象(p)
p.start()启动线程
进程间的通信
创建队列
q = multiprocessing.Queue()
放入数据
q.put(要放入的数据)
取出数据
q.get(True)阻塞(默认)
q.get(False)不阻塞
学习教程来源:BV1FS4y1v7CW