60116bb08c885a5fa911331c430384dd52213029,python/paddle_edl/distill/distill_reader.py,DistillReader,_start_predict_worker,#DistillReader#,1051

Before Change

    def _start_predict_worker(self):
        process = []
        for i in range(self._require_num):
            stop_flag = mps.Event()
            worker = mps.Process(target=self._predict_worker)
            worker.daemon = True
            worker.start()
            process.append(worker)

After Change

    def _start_predict_worker(self):
        process = []
        for i in range(self._require_num):
            worker = mps.Process(
                target=distill_worker.predict_worker,
                args=(
                    self._predict_server_queue,
                    self._predict_server_result_queue,
                    self._working_predict_count,
                    self._reader_out_queue,
                    self._predict_out_queue,
                    self._feeds,
                    self._fetchs,
                    self._serving_conf_file,
                    self._predict_stop_events,
                    self._predict_lock,
                    self._predict_finished_task,
                    self._predict_cond, ))
            worker.daemon = True
            worker.start()
            process.append(worker)
        return process

Instances