Python进程间通信Queue实例解析
本文研究的主要是Python进程间通信Queue的相关实例,具体如下。
1.Queue使用方法:
- Queue.qsize():返回当前队列包含的消息数量;
- Queue.empty():如果队列为空,返回True,反之False;
- Queue.full():如果队列满了,返回True,反之False;
- Queue.get():获取队列中的一条消息,然后将其从列队中移除,可传参超时时长。
- Queue.get_nowait():相当Queue.get(False),取不到值时触发异常:Empty;
- Queue.put():将一个值添加进数列,可传参超时时长。
- Queue.put_nowait():相当于Queue.get(False),当队列满了时报错:Full。
2.Queue使用实例:
来,上代码:
#!/usr/bin/envpython3 importtime frommultiprocessingimportProcess,Queue q=Queue()#创建列队,不传数字表示列队不限数量 foriinrange(11): q.put(i) defA(): while1: try: num=q.get_nowait() print('我是进程A,取出数字:%d'%num) time.sleep(1) except: break defB(): while1: try: num=q.get_nowait() print('我是进程B,取出数字:%d'%num) time.sleep(1) except: break p1=Process(target=A) p2=Process(target=B) p1.start() p2.start()
此程序是在队列中加入10个数字,然后用2个进程来取出。
运行结果:
我是进程A,取出数字:0
我是进程B,取出数字:1
我是进程A,取出数字:2
我是进程B,取出数字:3
我是进程A,取出数字:4
我是进程B,取出数字:5
我是进程B,取出数字:6
我是进程A,取出数字:7
我是进程B,取出数字:8
我是进程A,取出数字:9
我是进程B,取出数字:10
3.使用进程池Pool时,Queue会出错,需要使用Manager.Queue:
上代码
#!/usr/bin/envpython3 importtime frommultiprocessingimportPool,Manager,Queue q=Manager().Queue() foriinrange(11): q.put(i) defA(i): num=q.get_nowait() print('我是进程%d,取出数字:%d'%(i,num)) time.sleep(1) pool=Pool(3) foriinrange(10): pool.apply_async(A,(i,)) pool.close() pool.join()
运行结果:
我是进程1,取出数字:0
我是进程0,取出数字:1
我是进程2,取出数字:2
我是进程4,取出数字:3
我是进程3,取出数字:4
我是进程5,取出数字:5
我是进程6,取出数字:6
我是进程7,取出数字:7
我是进程8,取出数字:8
我是进程9,取出数字:9
当把Manager().Queue()直接换成Queue(),可能会出现资源混乱,缺少进程。
4.主进程定义了一个Queue类型的变量,并作为Process的args参数传给子进程processA和processB,两个进程一个向队列中写数据,一个读数据。
importtime frommultiprocessingimportProcess,Queue MSG_QUEUE=Queue(5) defstartA(msgQueue): whileTrue: ifmsgQueue.empty()>0: print'queueisempty%d'%(msgQueue.qsize()) else: msg=msgQueue.get() print'getmsg%s'%(msg,) time.sleep(1) defstartB(msgQueue): whileTrue: msgQueue.put('helloworld') print'puthelloworldqueuesizeis%d'%(msgQueue.qsize(),) time.sleep(3) if__name__=='__main__': processA=Process(target=startA,args=(MSG_QUEUE,)) processB=Process(target=startB,args=(MSG_QUEUE,)) processA.start() print'processAstart..' processB.start() print'processBstart..'
其打印的结果如下:
C:\Python27\python.exeE:/outofmemory/test/queuetest/queuetest.py
processAstart..
processBstart..
queueisempty0
puthelloworldqueuesizeis1
getmsghelloworld
queueisempty0
queueisempty0
puthelloworldqueuesizeis1
getmsghelloworld
queueisempty0
queueisempty0
puthelloworldqueuesizeis1
总结
以上就是本文关于Python进程间通信Queue实例解析的全部内容,希望对大家有所帮助。感兴趣的朋友可以继续参阅本站其他相关专题,如有不足之处,欢迎留言指出。感谢朋友们对本站的支持!