python - 画像のマルチプロセッシングとパイプ通信

Question

2 つのプロセッサを考慮して、イメージング パイプラインを高速化しようとしています。

1. 画像を取得してパイプに書き込む
2. 画像を読み取って計算する

したがって、パイプについて何か読んだことがあります。

import os 
from multiprocessing import Process, Pipe
import time
def ponger (p,s):
    msg = p.recv()
    print("Process{0} got message:{1}".format(os.getpid(),msg))
    time.sleep(1)
    p.send(s)


if __name__ == "__main__": 
    parent,child = Pipe()
    proc = Process(target = ponger, args = (child,"ping"))
    proc.start()
    parent.send("pong")
    ponger(parent,"pong")
    proc.join()

次に、2 つのプロセスを含むコード スニペットがあります。

if __name__ == '__main__':
    p_camera = Process(target = controlHardware,args = (SSHConnection,CameraInstance))
    p_featureExtraction = Process(target = processImage, args = ())

画像が 1 つ取得されるとすぐに、featureExtraction Processor に送信される画像を取得したいと考えています。したがって、上記のパイプの例を使用したいと思います。ただし、これら 2 つの例をまとめることはできませんでした。アドバイスをいただければ幸いです:)よろしくお願いします