code: def _run_parallel_multiprocess(self):
          
          _log.debug("run.parallel.multiprocess.start")
          processes = []
          ProcRunner.instance = self
          for i in range(self._ncores):
              self._status.running(i)
              proc = multiprocessing.Process(target=ProcRunner.run, args=(i,))
              proc.start()
              processes.append(proc)
          for i in range(self._ncores):
              processes[i].join()
              code = processes[i].exitcode
              self._status.success(i) if 0 == code else self._status.fail(i)
          _log.debug("run.parallel.multiprocess.end states={}".format(self._status))
docs: Run processes from queue