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() # 进程启动