process_controller.py 文件源码

def __init__(self, input_transcoder, output_transcoder, command=None, cwd=None, env=None):
        self.master = None
        self.slave = None
        self.process = None

        self.input_transcoder = input_transcoder
        self.output_transcoder = output_transcoder

        self.command = command
        self.cwd = cwd
        self.env = env

        self.mutex = Lock()
        self.read_thread = None
        self.write_thread = None
        self.stop = False