怎么在Python中使用Queue實現進程間通信

怎么在Python中使用Queue實現進程間通信？針對這個問題，這篇文章詳細介紹了相對應的分析和解答，希望可以幫助更多想解決這個問題的小伙伴找到更簡單易行的方法。

python可以做什么

Python是一種編程語言，內置了許多有效的工具，Python幾乎無所不能，該語言通俗易懂、容易入門、功能強大，在許多領域中都有廣泛的應用，例如最熱門的大數據分析，人工智能，Web開發等。

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實現進程間通信問題的解答就分享到這里了，希望以上內容可以對大家有一定的幫助，如果你還有很多疑惑沒有解開，可以關注億速云行業資訊頻道了解更多相關知識。