Python提供了非常好用的多進程包multiprocessing，只需要定義一個函數，Python會完成其他所有事情。借助這個包，可以輕松完成從單進程到并發執行的轉換。multiprocessing支持子進程、通信和共享數據、執行不同形式的同步，提供了Process、Queue、Pipe、Lock等組件。

????Pipe方法返回(conn1, conn2)代表一個管道的兩個端。Pipe方法有duplex參數，如果duplex參數為True(默認值)，那么這個管道是全雙工模式，也就是說conn1和conn2均可收發。duplex為False，conn1只負責接受消息，conn2只負責發送消息。
?
????send和recv方法分別是發送和接受消息的方法。例如，在全雙工模式下，可以調用conn1.send發送消息，conn1.recv接收消息。如果沒有消息可接收，recv方法會一直阻塞。如果管道已經被關閉，那么recv方法會拋出EOFError。

?

第一種：普通

from multiprocessing import Process, Pipe import timedef proc(pipe):time.sleep(1)a = Truepipe.send(a)if __name__ == '__main__':parentPipe, childPipe = Pipe(True)p = Process(target=proc, args=(childPipe,))p.start()while True:print(parentPipe.recv())print(111111) #測試堵塞

關閉Process創建的子進程

if p != None:p.terminate()

另一種進程通信，好像不如pipe管道好，數據多了就會在jion處堵塞出不來了

import random import time import multiprocessingdef worker(name, q):t = 0for i in range(10):print(name + " " + str(i))x = random.randint(1, 3)t += xtime.sleep(x * 0.1)q.put(t)q = multiprocessing.Queue() jobs = [] for i in range(10):p = multiprocessing.Process(target=worker, args=(str(i), q))jobs.append(p)p.start()for p in jobs:p.join()results = [q.get() for j in jobs] print(results)

?

總結

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

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。