Process之間肯定是需要通信的，操作系統(tǒng)提供了很多機制來實現(xiàn)進程間的通信。Python的multiprocessing模塊包裝了底層的機制，提供了Queue、Pipes等多種方式來交換數(shù)據(jù)。

一、我們以Queue為例，在父進程中創(chuàng)建兩個子進程，一個往Queue里寫數(shù)據(jù)，一個從Queue里讀數(shù)據(jù)：

from multiprocessing import Process,Queue import os,time,random # 寫數(shù)據(jù)進程執(zhí)行的代碼： def write(q):print("Process to write: %s"% os.getgid())for value in ['A','B','C']:print('Put %s to queue...' % value)q.put(value)time.sleep(random.random())#讀數(shù)據(jù)進程執(zhí)行的代碼 def read(q):print("Process to read: %s "% os.getgid())while True:value = q.get(True)print('Get %s from queue.' % value)if __name__ == '__main__':# 父進程創(chuàng)建Queue，并傳給各個子進程q = Queue()pw = Process(target=write, args=(q,))pr = Process(target=read, args=(q,))#啟動子進程pw,寫入：pw.start()#啟動子進程pr,讀取：pr.start()#等待pw結束pw.join()#pr進程這里是死循環(huán)，無法等待其結束，只能強行終止pr.terminate()

輸出：

Process to write: 15582
Put A to queue...
Process to read: 15583?
Get A from queue.
Put B to queue...
Get B from queue.
Put C to queue...
Get C from queue.

在Unix/Linux下，multiprocessing模塊封裝了fork()調(diào)用，使我們不需要關注fork()的細節(jié)。由于Windows沒有fork調(diào)用，因此，multiprocessing需要“模擬”出fork的效果，父進程所有Python對象都必須通過pickle序列化再傳到子進程去，所有，如果multiprocessing在Windows下調(diào)用失敗了，要先考慮是不是pickle失敗了。

二、管道Pipes

現(xiàn)有2個進程A和B，他們都在內(nèi)存中開辟了空間，那么我們在內(nèi)存中再開辟一個空間C，作用是連接這兩個進程的。對于進程來說內(nèi)存空間是可以共享的（任何一個進程都可以使用內(nèi)存，內(nèi)存當中的空間是用地址來標記的，我們通過查找某一個地址就能找到這個內(nèi)存）A進程可以不斷的向C空間輸送東西，B進程可以不斷的從C空間讀取東西，這就是進程間的通信???

??????這個通信方式的原理類似于用文件通信，一個進程往文件里寫，另外一個進程從文件里讀取，最大的不同在于管道里C的空間是開辟在內(nèi)存當中，第一是他不容易被截獲，第二是進程結束后內(nèi)存空間他會自動的釋放掉，文件就不能自動釋放掉。第三就是內(nèi)存的傳輸是不需要和磁盤交互，所以相比文件管道的傳輸效率要高很多，這就是管道的基本原理。

??????管道在信息傳輸上是以流的方式傳輸， 也就是你從A進程不斷的寫入，B進程源源不斷的讀出，A進程先寫入的就會被B進程先讀出，后寫進來的就會被后讀出，管道不僅僅可以讓A進程寫C內(nèi)存空間收，也可以B進程寫，C內(nèi)存空間收，也就是雙向通信，單項通信叫做半雙工，雙向叫做全雙工。

2.管道本質(zhì)
?????在內(nèi)存中開辟一個新的空間，對多個進程可見，在通信形式上形成一種約束

3.創(chuàng)建管道
?????multiprocessing------------->Pipe

?????1.首先理解Pipe是什么，有人理解為類，那到底是什么？

????????>>> from multiprocessing import Pipe
????????>>> type(Pipe)

????????????????<class 'method'>

???????可以看到是個方法，也就是函數(shù)，是通過函數(shù)的返回值來完成工作的，不是類
?

----------------------

待完善

?

參考：

（1）、https://www.liaoxuefeng.com/wiki/0014316089557264a6b348958f449949df42a6d3a2e542c000/001431927781401bb47ccf187b24c3b955157bb12c5882d000

（2）、https://blog.csdn.net/weixin_39859512/article/details/80898340

?

?

總結

以上是生活随笔為你收集整理的进程间通信（python）的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。