python--multiprocessing-下面的queue消息队列
今天接触的东西还挺多的哈。。。线程进程队列一起整了。。
消息队列的话理解起来也是挺简单的
主要是解决进程之间不能访问公用资源的问题,既保证了安全,有能去修改公用资源,
queue.put()入队列
queue.get()出队列
put_nowait()
get_nowait()
# 出入队列不等待。
empty()# 判断队列是否已空
full() # 判断队列是否为已满
multiprocessing.Queue(5)->括号内写的值就是队列的长度。
可以通多下面的例子来实现进程和进程之间的通信,
a=multiprocessing.Queue(5) 创建一个长度为5的队列
work1=multiprocessing.Process(target=n1,args=a) 创建一个work1进程
work2=multiprocessing.Process(target=21,args=a)创建一个work2进程
work1.start() # 进程启动
work1.join()# 进程优先执行
work2.start() # 进程启动