Python中使用Queue、Pipe怎么實現進程通信

今天就跟大家聊聊有關Python中使用Queue、Pipe怎么實現進程通信，可能很多人都不太了解，為了讓大家更加了解，小編給大家總結了以下內容，希望大家根據這篇文章可以有所收獲。

進程通信的概念

• 進程的資源空間是相互獨立的，一般而言是不能相互訪問的。但很多情況下進程間需要互相通信，來完成系統的某項功能。進程通過與內核及其它進程之間的互相通信來協調它們的行為。

• 通信方法：

• 數據傳輸：一個進程將它的數據發送給另一個進程【如socket一般，把需要通信的數據傳輸給對方】

• 管道：使用一片獨立的區域【不在雙方的資源空間中】，像一個有兩個口的倉庫一樣，廠家負責在東門把產品放到倉庫，司機負責在西門拉走產品

• 資源共享：約定一片區域，雙方都可以隨意取放

• 消息隊列：這也是一個獨立的區域，足夠權限的進程可以向隊列中添加消息，被賦予讀權限的進程則可以讀走隊列中的消息

Queue:

• 可以使用隊列multiprocessing.Queue來進行進程通信

Queue 在multiprocessing 模塊中:from multiprocessing import Queue

• Queue的使用：

• 1.創建對象：Queue對象=Queue()

• 2.傳入對象：要在主進程外使用Queue對象，需要作為參數傳入

• 3.操作對象：【獲取元素：Queue對象.get()】、【放入元素：Queue對象.put(元素)】

#Queue在multiprocessing中
from multiprocessing import Queue,Process

def f(q):#要在主進程外使用，需要作為參數傳入
  q.put(['helloworld'])
  

def m(q):
  print("get in p2:",q.get())

if __name__=="__main__":
  q=Queue()
  p=Process(target=f,args=(q,))
  p.start()
  p2=Process(target=m,args=(q,))
  p2.start()

Pipe:

• 可以使用管道Pipe來進行進程通信

Pipe 在multiprocessing 模塊中:from multiprocessing import Pipe

• Pipe的使用：

• 1.創建對象：第一個Pipe對象,第二個Pipe對象=Pipe(),返回兩個對象，第一個對象只能發，第二個對象只能收

• 2.傳入對象：在要發送的進程，傳入第一個Pipe對象;在要接收的進程，傳入第二個Pipe對象

• 3.操作對象：【獲取元素：第一個對象.recv()】、【放入元素：第二個對象.send(元素)】

• 4.操作完成后關閉管道:第一個對象.close(),第一個對象.close()

from multiprocessing import Pipe,Process

def f(conn):
  a=[1,2,3,4]
  conn.send(a)
  conn.close()
def m(conn):
  a=conn.recv()
  conn.close()


if __name__=="__main__":
  parent_conn,child_conn=Pipe()#返回兩個值，第一個只能發，第二個只能收
  p1=Process(target=f,args=(child_conn,))
  p2 = Process(target=m, args=(parent_conn,))#
  p1.start()
  p2.start()
  p1.join()
  p2.join()

看完上述內容，你們對Python中使用Queue、Pipe怎么實現進程通信有進一步的了解嗎？如果還想了解更多知識或者相關內容，請關注億速云行業資訊頻道，感謝大家的支持。