Jetson NANO 上的多处理

Question

我正在尝试在使用 Jetpack 4.5 闪存的 Jetson NANO 设备上运行一个简单的多处理系统。 我正在做我通常在电脑上做的事情，所以我有一个主脚本，launcher.py

launcher.py

import multiprocessing as mp
from multiprocessing import set_start_method, Queue, Event
from camera_reader import Camera_Reader_Initializer

def main():
    set_start_method("spawn")
    cam_read = mp.Process(target=Camera_Reader_Initializer, args=())
    cam_read.daemon = True
    cam_read.start()

if __name__ == "__main__":
    main()

应该启动脚本camera.py（实际上，连同其他几个脚本） camera.py：

camera.py

print("check 00")

def Camera_Reader_Initializer():
    print('check 01')
    cam_read = Camera_Reader()
    cam_read.run()


class Camera_Reader():
    def __init__(self):
        print('check 02)
        self.source = "/dev/video0"

    def run(self):
        print('check 03')
        input = jetson.utils.videoSource(self.source)
        output = jetson.utils.videoOutput("")
        while output.IsStreaming():
            image = input.Capture(format='rgb8')
            output.Render(image)
            output.SetStatus(f"Video Viewer | {image.width:d}x{image.height:d} | {output.GetFrameRate():.1f} FPS")

但是，在运行 launcher.py 时，我得到的唯一输出是：

check 00

所以，基本上 cam_read 对象没有被创建或运行。我做错了吗？

Answer 1

设置Process.daemon = True的功能会导致主进程在退出时调用Process.terminate()。这适用于可以处理在没有警告的情况下关闭的长时间运行的子进程（通常您应该在退出之前处理SIGTERM 信号以进行清理）。

您在“launcher.py”中的主要功能不会等待孩子做任何事情，并且基本上会立即尝试退出。在孩子被杀之前，似乎有足够的时间到达print("check 00") 行。这可能看起来有些一致，但不应该指望它甚至打印出来。这是在主进程开始关闭之前子进程可以完成多少工作之间的竞赛。

解决此问题取决于您希望它如何运行。如果您仍然希望子进程在主进程退出之前一直在后台运行，则需要确保主进程需要一些时间（可能使用time.sleep）。如果孩子正在完成一些有限的工作，它可能不应该是一个守护进程，你应该在它上面调用Process.join() 以等待它在main() 中的某个时间点完成。