code: def _run_process(self, start_path, stop_path, process_num=0):
          
          # pre processing
          self.producer.initialize_worker(process_num)
          self.consumer.initialize_worker(process_num)
  
          # processing
          for path in range(start_path, stop_path):
              self._run_path(path)
  
          # post processing
          self.consumer.finalize_worker(process_num)
docs: The function calls _run_path for given set of paths