process.py 文件源码

def __init__(self, desc_cb, ws):
        self.ws = ws

        self.pipe_r_sd, self.pipe_w_sd = os.pipe()
        os.set_inheritable(self.pipe_w_sd, True)

        self.desc_cb = desc_cb

        self.processed = -1
        self.do_stop = False

        process = threading.Thread(target=self.process_loop)
        process.start()