本文實例講述了Python進程的通信Queue、Pipe。分享給大家供大家參考，具體如下：

內容相關：

概念：進程的通信

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,Processdef 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,Processdef 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相關內容感興趣的讀者可查看本站專題：《Python進程與線程操作技巧總結》、《Python數據結構與算法教程》、《Python函數使用技巧總結》、《Python字符串操作技巧匯總》、《Python入門與進階經典教程》、《Python+MySQL數據庫程序設計入門教程》及《Python常見數據庫操作技巧匯總》

希望本文所述對大家Python程序設計有所幫助。