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/env python3



import time

from multiprocessing import Process,Queue



q = Queue() #创建列队，不传数字表示列队不限数量

for i in range(11):

  q.put(i)



def A():

  while 1:

    try:

      num = q.get_nowait()

      print('我是进程A,取出数字:%d'%num)

      time.sleep(1)

    except :

      break



def B():

  while 1:

    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/env python3



import time

from multiprocessing import Pool,Manager,Queue



q = Manager().Queue()

for i in range(11):

  q.put(i)



def A(i):

  num = q.get_nowait()

  print('我是进程%d,取出数字:%d'%(i,num))

  time.sleep(1)

      



pool = Pool(3)



for i in range(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，两个进程一个向队列中写数据，一个读数据。





import time

from multiprocessing import Process,Queue



MSG_QUEUE = Queue(5)



def startA(msgQueue):

  while True:

    if msgQueue.empty() > 0:

      print 'queue is empty %d' % (msgQueue.qsize())

    else:

      msg = msgQueue.get()

      print 'get msg %s' % (msg,)

    time.sleep(1)



def startB(msgQueue):

  while True:

    msgQueue.put('hello world')

    print 'put hello world queue size is %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 'processA start..'



  processB.start()

  print 'processB start..'



其打印的结果如下：



C:\Python27\python.exe E:/outofmemory/test/queuetest/queuetest.py

processA start..

processB start..

queue is empty 0

put hello world queue size is 1

get msg hello world

queue is empty 0

queue is empty 0

put hello world queue size is 1

get msg hello world

queue is empty 0

queue is empty 0

put hello world queue size is 1



总结

以上就是本文关于Python进程间通信Queue实例解析的全部内容，希望对大家有所帮助。感兴趣的朋友可以继续参阅本站其他相关专题，如有不足之处，欢迎留言指出。感谢朋友们对本站的支持！